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

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

java Queue处理

实例代码：

import java.util.LinkedList;

import java.util.Queue;

private static Queue frameQueue = new LinkedList();

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[byteCoWHGTzMOunt];

frame.len = byteCount;

System.arraycopy(frameData, 0, frame.buf, 0, byteCount);

lock.lock();

frameQueue.offer(frame);

lock.unlock();

感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。