Chan doesn't have join operation, need to find another thread-safe queue
implementation.