在多个线程上同步Java中的队列
发布时间:2020-12-15 04:20:38 所属栏目:Java 来源:网络整理
导读:我理解同步的概念,但我现在确定它为什么以这种方式实现,所以我需要一点帮助: 我有2个帖子: PeriodicalThread将定期接收数据(假设每5秒)并将其放入队列中(目前使用ArrayDeque,但我不知道其他任何Queue实现是否会更好) ProccessThread将不断检查队列以查看它
我理解同步的概念,但我现在确定它为什么以这种方式实现,所以我需要一点帮助:
我有2个帖子: PeriodicalThread将定期接收数据(假设每5秒)并将其放入队列中(目前使用ArrayDeque,但我不知道其他任何Queue实现是否会更好) ProccessThread将不断检查队列以查看它是否为空.如果它不为空,它将处理数据(FIFO). 所以,起初我的实现将是: // Both threads are inner class so they have access to Queue private Queue queue; private boolean isReadyToProccess; class PeriodicalThread extends Thread { public void run() { while(true) { if(isNewDataAvailable) { // create Data object queue.add(data); } } } } class ProcessThread extends Thread { public void run() { while(true) { if(!queue.isEmpty() && isReadyToProccess) { Data data = queue.poll(); processData(data); } } } } private void processData(Data data) { // this method send data over network,and the server response callback // changes isReadyToProcess value to true. } 然后当想要处理同步时,我不知道我是否应该使用一个锁对象(以及它是如何实现的),或者是否已经存在一个线程安全的包Queue实现(因为add()和poll( ) 方法) 编辑:我忘了标志isReadyToProcess指示下一个队列数据对象是……好,准备好进行处理.此标志也应同步. 解决方法
ArrayDeque不支持并发.相反,使用支持并发工作的真实队列,如
BlockingQueue 及其在java.util.concurrent包中的一个实现.我建议使用
LinkedBlockingQueue .
如果您需要在线程之间共享标志,最好使用 注意:如果您将使用并发进程,最好使用已支持锁定和同步开箱即用的 (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |
相关内容
- 当TrustManagerFactory不是TrustManagerFactory(Java)
- Java网络编程之TCP通信完整代码示例
- java – 数字文字后缀大小写的编码指南
- java – 基于Spring Boot的测试中的上下文层次结构
- java – 如何在同一数据库表上映射两个JPA或Hibernate实体
- Java List.contains()方法:判断列表中是否包含指定元素
- java – 使用GSON修改json而不使用POJO
- java – Camera.Parameters设备特定崩溃(三星S3 Mini)
- java – 在Gradle缓存中没有创建Gradle依赖项?
- Javafx可拆卸窗格系统