Selector部分,看到你用到Object作為線程間通信的方式,直接用https://stackoverflow.com/questions/831834/blockingqueue-blocked-drainto-methods
給出的方案是否會更好?
list.add(blockingQueue.take());
blockingQueue.drainTo(list);
Reactor模式詳解+源碼實現(xiàn)1.Reactor模式介紹 Reactor模式是事件驅(qū)動模型,有一個或多個并發(fā)輸入源,有一個Service Handler,有多個Request Handlers;這個Ser...