我理解同步的概念,但我现在确定它为什么以这种方式实现,所以我需要一点帮助:
我有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
.
如果您需要在线程之间共享标志,最好使用AtomicBoolean
而不是手动同步基本布尔字段.
注意:如果您将使用并发进程,最好使用已支持锁定和同步开箱即用的java.util.concurrent
程序包提供的类.
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。