加入一组具有整体超时的线程

Question

有没有办法在总超时的情况下同时加入一组线程？

假设我们有集合

for (Thread t : threads)
    t.join();

但我想等到所有线程都完成，或者经过一定的时间，以先到者为准。我正在搜索一个（假设的）<代码>线程组。join（int）将执行此操作。

请注意，我所要求的与所做的不同

for (Thread t : threads)
    t.join(timeout);

更确切地说，我正在寻找比

int timeout = 10000;
for (Thread t : threads) {
    if (timeout <= 0) break;

    long start = System.currentTimeMillis();
    t.join(timeout);
    long end = System.currentTimeMillis();

    // substract time elapsed from next timeout:
    timeout -= (int) (end - start);
}

Answer 1

首先创建一个CountDownLatch，其中包含组中每个线程的计数。

控制线程可以在闩锁上等待（超时，时间单位）。

https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CountDownLatch.html#await-长java。util。同时发生的时间单位-

启动组中的线程。

组中的每个线程应在锁存完成时减少锁存。

控制线程将等待组中的所有内容完成或发生超时，并且由于wait返回布尔值，因此控制线程可以判断闩锁是自然递减还是发生超时。