相关疑难解决方法(0)

我在我的多线程应用程序中使用了Java Executors,但我似乎无法弄清楚何时最好使用以下各种方法:

1.

ExecutorService executor=Executors.newFixedThreadPool(50);
executor.execute(new A_Runner(... some parameter ...));
executor.shutdown();
while (!executor.isTerminated()) { Thread.sleep(100); }

2.

int Page_Count=200;
ExecutorService executor=Executors.newFixedThreadPool(50);
doneSignal=new CountDownLatch(Page_Count);
for (int i=0;i<Page_Count;i++) executor.execute(new A_Runner(doneSignal, ... some parameter ...));
doneSignal.await();
executor.shutdown();
while (!executor.isTerminated()) { Thread.sleep(100); }

3.

int Executor_Count=30;
ThreadPoolExecutor executor=new ThreadPoolExecutor(Executor_Count,Executor_Count*2,1,TimeUnit.SECONDS,new LinkedBlockingQueue());
List<Future<String>> futures=new ArrayList<>(3330);

for (int i=0;i<50;i++) futures.add(executor.submit(new A_Runner(... some parameter ...));
executor.shutdown();
while (!executor.isTerminated()) { executor.awaitTermination(1,TimeUnit.SECONDS); }
for (Future<String> future : futures)
{
    String f=future.get();
    // ...
}

具体来说,在[2]中,如果我跳过doneSignal,那么它就像[1],那么doneSignal的用途是什么？

另外,在[3]中,如果我添加一个doneSignal怎么办？或者有可能吗？

我想知道的是:这些方法是否可以互换,或者是否存在我应该使用上述特定类型的某种情况？

在典型的JAVA应用程序中，可以配置一个全局ExecutorService来管理全局线程池。可以说我配置了100个线程的固定线程池：

ExecutorService threadPool = Executors.newFixedThreadPool(100);

现在假设我有一个要上传到服务器的1000个文件的列表，对于每次上传，我都会创建一个可调用的文件，以处理该文件的上传。

List<Callable> uploadTasks = new ArrayList<Callable>();
// Fill the list with 1000 upload tasks

我如何将最大同时上传数量限制为5个？

如果我做

threadPool.invokeAll(uploadTasks);

我无法控制我的1000个任务要执行多少个线程。可能并行运行100个上载，但我只希望最多5个。我想创建某种子执行器，它使用父执行器线程的子集。我不想仅为上传而创建一个新的单独的executorService，因为我想全局管理我的线程池。

你们中的任何人都知道该怎么做或是否存在现有的实现吗？理想情况是

ExecutorService uploadThreadPool = Executors.createSubExecutor(threadPool,5);

非常感谢，

安托万