利用共享变量 synchronized/notify/waitlock/conditionvolatileAtomicInteger CyclicBarrierPipedInputStream 管道``BlockingQueue