您好,登錄后才能下訂單哦!
如何正確的使用ThreadPoolExecutor線程池,相信很多沒(méi)有經(jīng)驗(yàn)的人對(duì)此束手無(wú)策,為此本文總結(jié)了問(wèn)題出現(xiàn)的原因和解決方法,通過(guò)這篇文章希望你能解決這個(gè)問(wèn)題。
import java.util.Random;
import java.util.concurrent.*;
public class PoolTest {
private BlockingQueue<Runnable> workingQueue = new ArrayBlockingQueue<Runnable>(10);
private RejectedExecutionHandler rejectedExecutionHandler = new ThreadPoolExecutor.CallerRunsPolicy();
private ExecutorService threadPool = new ThreadPoolExecutor(10, 10, 0L, TimeUnit.MILLISECONDS, workingQueue, rejectedExecutionHandler);
private Random random = new Random();
public void test() {
int size = 10;
final CountDownLatch latch = new CountDownLatch(size);
for(int i = 0; i < size; i ++) {
threadPool.execute(new Runnable() {
int x = random.nextInt(10);
@Override
public void run() {
try {
plus(x,x);
} finally {
latch.countDown();
}
}
});
}
try {
latch.await();
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
System.out.println("線程全部執(zhí)行完成");
}
threadPool.shutdown();
}
public void plus(int x, int y) {
System.out.println("sum = " + (x + y));
}
public static void main(String[] args) {
PoolTest poolTest = new PoolTest();
poolTest.test();
}
}
看完上述內(nèi)容,你們掌握如何正確的使用ThreadPoolExecutor線程池的方法了嗎?如果還想學(xué)到更多技能或想了解更多相關(guān)內(nèi)容,歡迎關(guān)注億速云行業(yè)資訊頻道,感謝各位的閱讀!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。