Searched refs:messageQueue (Results 1 – 2 of 2) sorted by relevance
67 protected LinkedList messageQueue; field in UDPMessageProcessor103 this.messageQueue = new LinkedList(); in UDPMessageProcessor()204 if ( this.messageQueue.size() >= HIGHWAT) { in run()211 … } else if ( this.messageQueue.size() > LOWAT && this .messageQueue.size() < HIGHWAT ) { in run()213 … float threshold = ((float)(messageQueue.size() - LOWAT))/ ((float)(HIGHWAT - LOWAT)); in run()238 synchronized (this.messageQueue) { in run()240 this.messageQueue.add(packet); in run()241 this.messageQueue.notify(); in run()255 synchronized (this.messageQueue) { in run()256 this.messageQueue.notifyAll(); in run()[all …]
258 synchronized (((UDPMessageProcessor) messageProcessor).messageQueue) { in run()259 while (((UDPMessageProcessor) messageProcessor).messageQueue in run()278 ((UDPMessageProcessor) messageProcessor).messageQueue in run()286 packet = (DatagramPacket) ((UDPMessageProcessor) messageProcessor).messageQueue in run()