使用BlockingQueue进行多线程间的异步通信

本文主要是介绍使用BlockingQueue进行多线程间的异步通信，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

写单元测试时遇到一个问题，我要获取一串数据复制给一个变量，但获取数据的操作比较耗时（这里是http请求），且耗时长短不定。我当然不能让这种耗时操作阻塞主线程，于是每次获取数据，我都开了一个新线程，把操作放到线程里去完成。

问题出现在这：由于获取数据是在线程里的，所以我并不知道它什么时候被获取到了，只能等待一段时间（肯定比它需要的时间略长），然后去访问这个变量。

这种方式最大的问题不是盲目的等待了一段时间，而是就算我等待了很长时间，十几秒甚至几十秒，我也并不能保证这个变量已经被赋值了。所以我的操作很像是赌运气。根据概率原理90%以上的情况我能获取到数据，但如果这种操作需要重复几百次甚至更多时，失败的情形就会接二连三的蹦出来，我不得不为了这些case不断的增加等待的时间。

解决这个问题的方法就是：使用blockingqueue。它简直就是为了解决这种问题而设计的。

其实我的问题抽象一下可以是这样：我在一个类中得到了一个值，我想通过另一个类去获取这个值（异步地），应该怎样做？

答案是你可以在主线程中初始化一个BlockingQueue，将它作为参数传递给一个线程，然后将获取到的数据放到这个queue里。你在主线程中想获取数据时，直接去queue中取。什么？你说如果你访问时数据还没有取到怎么办？答案是你可以在取数据时传入一个超时时长，你可以把它设的很大，如果这次访问没有取到数据，它会等待直到有数据或者超时。这种方法比盲目等待要省不少时间，而且增加了确定性。

BlockingQueue来自java.util.concurrent包，java自家的类，使用起来非常方便（其实concurrent包中有很多大大优化了多线程操作的类）。

这篇关于使用BlockingQueue进行多线程间的异步通信的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---