缓存期货并在它们完成时使用

Question

我想知道是否有办法缓存 Futures 以便在它们完成时使用。例如，我有一个主线程，它产生一个从输入流中读取的执行器：

// pseudo code
while(true){
   Callable task = new Callable({
      // setup callable stuff here
      byte[] call(){
        return inputStream.readInBytes();
      }
   });
   Future f = executors.submit(task);
   byte[] b = f.get();  // blocks   Uggh

   // execute of b
   process(b);
}

我想知道是否有办法将期货放入一个集合中，然后在它们完成时进行处理。

// pseudo code
while(true){
   Callable task = new Callable({
      // setup callable stuff here
      byte[] call(){
        return inputStream.readInBytes();
      }
   });
   Future f = executors.submit(task);

   futures.add(f);

   // process bytes as they completed.
   for(Future f: futures){
       if(f.isDone()){   // this doesn't always return valid.  It sometimes throws NPE's
         b = f.get();
         process (b);
       }
   }

}

我已经尝试了第二个代码片段，但它有时会抛出 NPE - 我假设在刚刚启动的线程上调用了“isDone”方法，这是问题所在（猜测）。

有人知道在期货开始完成之前缓存期货的方法吗？现在我的程序连续运行，但我正在寻找优化和加速它的方法。

谢谢

Answer 1

我不会使用Byte[]，而是使用byte[] 或可回收的缓冲区。

如果您想在数据可用时对其进行处理，请在后台线程中进行。

/* loop */ {
   futures.add(new Callable<Result>() {
      // setup callable stuff here
      Result call(){
           byte[] bytes = inputStream.readInBytes();
           return process(bytes);
      }
   });
}

// collect the results
for(Future<Result> f: futures){
    Result result = g.get();
    // do something single thread
}