SwingWorker 的 ExecutorService 参数

Question

我有一个扩展 SwingWorker 的抽象类，名为 FetchWorker，用于获取一些后台数据并修改为我的应用程序获取的数据。在我的FetchWorker 中是StatisticLayerController 的内部类。此 StatisticLayerController 由两个类扩展。我在FetchWorker 中初始化新线程以进行一些计算。我以前用TrackHistoryLayerController.的ExecutorService

如下：

public class TrackHistoryLayerController extends StatisticLayerController
{
   private final ExecutorService heatMapAdderExecutor;
   ...

   public AdsbFetchWorker(...)  extends FetchWorker
   {
      super(...);
   }

   @Override
   protected final List<ADSBTrack> doInBackground() throws Exception
   {
      filtered.forEach( track -> {
         this.heatMapAdderExecutor.submit( new HeatmapAdderHelper( ... ) );
      } );
      while ( this.latch.getCount() != 0 )
      {
         this.publishValue( ( int ) this.latch.getCount() );
      }
      this.latch.await();
      this.publishValue( ( int ) this.latch.getCount() );
      if ( this.createImage() )
      {
         this.placeImage();
      }
      return filtered;
   }
}

所以在这种情况下HeatMapAdderHelper 是我的助手线程，它为我做一些计算。一切正常，一切都很好。 但是现在我想多改变一点类结构，我想让我的Controller 类abstract 并且我不再希望我的Worker 类成为一个内部类。

---

我的问题是，我不能（不应该）在 Worker 内创建 ExecutorService，因为每次调用事件时都会初始化工作程序。我唯一能做的就是将 ExecutorService 从Controller 作为参数传递给SwingWorker，但这是一个好习惯吗？提前谢谢你。

Answer 1

你当然也可以直接使用CompletableFuture提供的默认ExecutorService做

filtered.forEach( track -> {
     CompletableFuture.runAsync(new HeatmapAdderHelper( ... ) );
  } );

顺便说一句，这个

  while ( this.latch.getCount() != 0 )
  {
     this.publishValue( ( int ) this.latch.getCount() );
  }
  this.latch.await();
  this.publishValue( ( int ) this.latch.getCount() );

看起来很狡猾...等待结果时的繁忙循环？另外，为什么你已经在循环中等待之后await 锁存器？假设闩锁是CountDownLatch。

我敢肯定，如果您提供更多上下文，我们可以提供更好的整体解决方案。

看起来你可以做类似的事情

CompletableFuture<Void>[] futures = 
     filtered.stream().map(t -> new HeatmapAdderHelper(t))
                 .map(CompletableFuture::runAsync)
                 .toArray(CompletableFuture[]::new);
CompletableFuture.allOf(futures).andThen(createImage());

或者CountDownLatch:

CountDownLatch latch = new CountDownLatch(filtered.size());
filtered.forEach(f -> {
    CompletableFuture.runAsync(new HeatmapAdderHelper(f))
                     .thenRun(latch::countDown);
});
latch.await();
createImage();