我有一个提供条件变量的同步队列。当数据添加到队列时，条件变量会发出信号。我有5个线程:Thread.newdoloopdo@queue.synchronize{cond.wait_until{@queue.has_data?||@queue.finished?}}#someprocessingcodethatcanalsocall@queue.enqueueendend然后我做:@queue.enqueuesome_data@threads.each(&:join)MyQueue#enqueue看起来像这样:defenqueue(data)synchronizedo@pending然后