JAVA 数据结构之Queue处理实例代码

import java.util.LinkedList;import java.util.Queue;private static Queue<FrameStruct> frameQueue = new LinkedList<FrameStruct>();private static Lock lock = new ReentrantLock();private PlayerThread p = new PlayerThread();

private class PlayerThread extends Thread {    @Override    public void run() {      FrameStruct frame;      while(bPlayRun)      {        if(bCanFlush)        {          lock.lock();          while((frame=frameQueue.poll())!=null)          {            onFrame(frame.buf, 0, frame.len);            try {              Thread.sleep(30);            } catch (InterruptedException e) {            }          }          lock.unlock();        }      }    }  }

FrameStruct frame = new FrameStruct();frame.buf = new byte[byteCount];frame.len = byteCount;System.arraycopy(frameData, 0, frame.buf, 0, byteCount);lock.lock();frameQueue.offer(frame);lock.unlock();