代码结构描述如下：
for (int i = 0; i < 5; i++) {
new Thread(new Runnable(){}).start();
new Thread(new Runnable(){}).start();
}for循环中的两个线程，前者是生产者，后者是消费者，他们通过定义一个：
public static BlockingQueue<Object> taskQueue = new ArrayBlockingQueue<Object>(2500);
联系起来，现在想for循环第一次执行完之后，两个线程的生产者全生产完数据，消费者全部消费完数据之后，再执行for循环的第二次循环。
在对代码结构改动最小的情况下，我考虑了callable countdownlatch，都不太合适，有没有更好的解决方案呢？
改造一下试试使用java.util.concurrent.CompletionService