-
1 votesanswersviews
完整队列上的java blockqueue使用者阻止
我正在编写一个小程序，将Twitter公共流中的推文放入HBase数据库 . 该程序使用两个线程，一个用于收集推文，另一个用于处理它们 . 第一个线程使用twitter4j StatusListener来获取推文并将它们放入容量为100的ArrayBlockingQueue中 . 第二个线程从队列中获取状态，过滤所需的数据并将它们移动到数据库 . 处理需要比收集状态更多的时间 . 制片人看起来像这...