java Queue处理
实例代码：
?
|
1
2
3
4
5
|
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();
|
从队列取数据进行处理：
?
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
|
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();
}
}
}
}
|
另一线程将数据放入队列：
?
|
1
2
3
4
5
6
7
|
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();
|
感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！
相关文章
猜你喜欢
- ASP.NET本地开发时常见的配置错误及解决方法？ 2025-06-10
- ASP.NET自助建站系统的数据库备份与恢复操作指南 2025-06-10
- 个人网站服务器域名解析设置指南：从购买到绑定全流程 2025-06-10
- 个人网站搭建：如何挑选具有弹性扩展能力的服务器？ 2025-06-10
- 个人服务器网站搭建：如何选择适合自己的建站程序或框架？ 2025-06-10
