Lock queueLock = new ReentrantLock(); Queue<Frame> mFrameQueue = new LinkedList<Frame>(); 入队 queueLock.lock(); while(true) { Frame oFrame = (Frame)this.mFrameQueue.peek(); if (oFrame == null) { break; } } this.mFrameQueue.offer(frame); queueLock.unlock(); 出队 queueLock.lock(); Frame frame = (Frame)this.mFrameQueue.poll(); queueLock.unlock(); |
|