我看到這個(gè)問題被問了很多次绎谦。很抱歉再次問這個(gè)問題。我有個(gè)奇怪的問題显歧。
我有一個(gè)通過ExecutorService作為單獨(dú)的可運(yùn)行任務(wù)提交數(shù)千個(gè)作業(yè)的職務(wù)蒙挑。這是在一個(gè)簡單的for循環(huán)中完成的。在for循環(huán)的末尾颖系，我調(diào)用service.候機(jī)()嗅剖，然后是一個(gè)等待高潮。
由于要提交的線程數(shù)量很大嘁扼，所以線程一直掛起信粮，直到所有任務(wù)都提交為止。
有任何方法趁啸，這些線程可以優(yōu)雅地終止强缘，一旦它的執(zhí)行完成督惰？
您可以創(chuàng)建一個(gè)新的ThreadPoolExecuto不打電話java.util.concurrent.Executors :
int corePoolSize = 0;
int maximumPoolSize = 64;
int keepAliveTime = 5000;
ExecutorService executorService =
new ThreadPoolExecutor(corePoolSize, maximumPoolSize, keepAliveTime,
TimeUnit.MILLISECONDS, new SynchronousQueue<Runnable>());
在javadoc中：“如果池當(dāng)前有多個(gè)corePoolSize線程，那么如果多余的線程已經(jīng)空閑超過了持有AliveTime旅掂，那么多余的線程將被終止”
編輯：
下面是一個(gè)很小的例子赏胚，如果您在Eclipse調(diào)試環(huán)境中運(yùn)行這個(gè)示例，您應(yīng)該可以看到線程的來來去去：
import java.util.Random;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.SynchronousQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
public class ExecutorTest {
public static void main(String[] args) {
ExecutorService executorService = new ThreadPoolExecutor(0, 64, 1000,
TimeUnit.MILLISECONDS, new SynchronousQueue<Runnable>());
for (int i = 0; i <= 500; i ++) {
try {
Thread.sleep(new Random().nextInt(200));
} catch (InterruptedException e) {
}
executorService.submit(new TestTask());
}
}
public static class TestTask implements Runnable {
public void run() {
try {
Thread.sleep(new Random().nextInt(1500));
} catch (InterruptedException e) {
}
}
}
}
