Initial core.async port
Increase buffers
Switch to real threads