1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 | class QueueFullCondition extends WaitWithTiming { public QueueFullCondition (ActiveQueue aq) { super (aq); } // 为WaitWithTiming中的object_赋值 public boolean condition () { ActiveQueue aq = (ActiveQueue) object_; //使用ActiveQueue来实现具体的判断逻辑 return aq.isFull (); } } class ActiveQueue { ... public synchronized void enqueue(ClientRequest cr, long timeout) throws InterruptedException, TimeoutException { //具有时限控制的等待 queueFullCondition_.timedWait (timeout); // 把用户请求添加进队列 //唤醒等待在ActiveQueue上的线程 queueFullCondition_.announce (); } ... private QueueFullCondition queueFullCondition_ = new QueueFullCondition (this); } |
欢迎光临 电子技术论坛_中国专业的电子工程师学习交流社区-中电网技术论坛 (http://bbs.eccn.com/) | Powered by Discuz! 7.0.0 |