使用BlockingQueue进行多线程间的异步通信
2014-08-10 15:12
645 查看
写单元测试时遇到一个问题,我要获取一串数据复制给一个变量,但获取数据的操作比较耗时(这里是http请求),且耗时长短不定。我当然不能让这种耗时操作阻塞主线程,于是每次获取数据,我都开了一个新线程,把操作放到线程里去完成。
问题出现在这:由于获取数据是在线程里的,所以我并不知道它什么时候被获取到了,只能等待一段时间(肯定比它需要的时间略长),然后去访问这个变量。
这种方式最大的问题不是盲目的等待了一段时间,而是就算我等待了很长时间,十几秒甚至几十秒,我也并不能保证这个变量已经被赋值了。所以我的操作很像是赌运气。根据概率原理90%以上的情况我能获取到数据,但如果这种操作需要重复几百次甚至更多时,失败的情形就会接二连三的蹦出来,我不得不为了这些case不断的增加等待的时间。
解决这个问题的方法就是:使用blockingqueue。它简直就是为了解决这种问题而设计的。
其实我的问题抽象一下可以是这样:我在一个类中得到了一个值,我想通过另一个类去获取这个值(异步地),应该怎样做?
答案是你可以在主线程中初始化一个BlockingQueue,将它作为参数传递给一个线程,然后将获取到的数据放到这个queue里。你在主线程中想获取数据时,直接去queue中取。什么?你说如果你访问时数据还没有取到怎么办?答案是你可以在取数据时传入一个超时时长,你可以把它设的很大,如果这次访问没有取到数据,它会等待直到有数据或者超时。这种方法比盲目等待要省不少时间,而且增加了确定性。
BlockingQueue来自java.util.concurrent包,java自家的类,使用起来非常方便(其实concurrent包中有很多大大优化了多线程操作的类)。
问题出现在这:由于获取数据是在线程里的,所以我并不知道它什么时候被获取到了,只能等待一段时间(肯定比它需要的时间略长),然后去访问这个变量。
这种方式最大的问题不是盲目的等待了一段时间,而是就算我等待了很长时间,十几秒甚至几十秒,我也并不能保证这个变量已经被赋值了。所以我的操作很像是赌运气。根据概率原理90%以上的情况我能获取到数据,但如果这种操作需要重复几百次甚至更多时,失败的情形就会接二连三的蹦出来,我不得不为了这些case不断的增加等待的时间。
解决这个问题的方法就是:使用blockingqueue。它简直就是为了解决这种问题而设计的。
其实我的问题抽象一下可以是这样:我在一个类中得到了一个值,我想通过另一个类去获取这个值(异步地),应该怎样做?
答案是你可以在主线程中初始化一个BlockingQueue,将它作为参数传递给一个线程,然后将获取到的数据放到这个queue里。你在主线程中想获取数据时,直接去queue中取。什么?你说如果你访问时数据还没有取到怎么办?答案是你可以在取数据时传入一个超时时长,你可以把它设的很大,如果这次访问没有取到数据,它会等待直到有数据或者超时。这种方法比盲目等待要省不少时间,而且增加了确定性。
BlockingQueue来自java.util.concurrent包,java自家的类,使用起来非常方便(其实concurrent包中有很多大大优化了多线程操作的类)。
相关文章推荐
- 使用WebService进行异步通信
- 使用WebService进行异步通信
- !!c# 委托与多线程 -- 相比background来说,本方法针对当需要通过异步代理发起UI操作,而后线程中进行sleep操作的时使用
- 用 ConTest 进行多线程单元测试 - 为什么并行测试很困难以及如何使用 ConTest 辅助测试
- 使用Actor模型对词频统计程序进行多线程优化
- python 进行多线程编程,使用Semaphore控制线程数
- 多线程和并发中BlockingQueue的使用
- 5.1多线程使用(不带参数的构造函数进行定义多线程)
- 使用Actor模型对词频统计程序进行多线程优化-Anran
- 使用Thread包装类进行多线程操作
- 使用WebService进行异步通信
- 使用pthread库进行多线程编程2 - UNIX高级环境编程第12章读书笔记
- 使用pthread库进行多线程编程2 - UNIX高级环境编程第12章读书笔记
- 使用pthread库进行多线程编程1 - UNIX环境高级编程第11章读书笔记
- 在Windows Embedded CE下进行Native C++开发,一次错误使用多线程的经验教训
- 使用WebService进行异步通信
- 使用pthread库进行多线程编程1 - UNIX环境高级编程第11章读书笔记
- 使用pthread库进行多线程编程1 - UNIX环境高级编程第11章读书笔记
- 在多线程应用程序中使用循环缓冲区高效地进行日志记录
- [多线程]使用信号量进行同步