JAVA 데이터 구조의Queue 처리 실례 코드

javaQueue 처리
인스턴스 코드:

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();

읽어주셔서 감사합니다. 여러분에게 도움이 되었으면 좋겠습니다. 본 사이트에 대한 지지에 감사드립니다!