這期內(nèi)容當(dāng)中小編將會(huì)給大家?guī)?lái)有關(guān)java中怎么利用多線程批量執(zhí)行任務(wù),文章內(nèi)容豐富且以專(zhuān)業(yè)的角度為大家分析和敘述,閱讀完這篇文章希望大家可以有所收獲。
目前成都創(chuàng)新互聯(lián)公司已為上千多家的企業(yè)提供了網(wǎng)站建設(shè)、域名、網(wǎng)絡(luò)空間、成都網(wǎng)站托管、企業(yè)網(wǎng)站設(shè)計(jì)、永豐網(wǎng)站維護(hù)等服務(wù),公司將堅(jiān)持客戶(hù)導(dǎo)向、應(yīng)用為本的策略,正道將秉承"和諧、參與、激情"的文化,與客戶(hù)和合作伙伴齊心協(xié)力一起成長(zhǎng),共同發(fā)展。
import java.util.*; import java.util.concurrent.*; public class TestThread { public static void main(String[] args) throws ExecutionException, InterruptedException { System.out.println("----程序開(kāi)始運(yùn)行----"); Date beginTime = new Date(); // 創(chuàng)建一個(gè)線程池,容量為3 ExecutorService pool = Executors.newFixedThreadPool(3); List> list = new LinkedList<>(); // 創(chuàng)建10個(gè)有返回值的任務(wù) for (int i = 0; i < 10; i++) { Callable c = new MyCallable(i + " "); // 執(zhí)行任務(wù)并獲取Future對(duì)象 Future f = pool.submit(c); list.add(f); } // 關(guān)閉線程池:會(huì)在所有任務(wù)執(zhí)行完成后關(guān)閉線程池,但并不會(huì)阻塞程序運(yùn)行 pool.shutdown(); // 獲取所有并發(fā)任務(wù)的運(yùn)行結(jié)果 for (Future f : list) { System.out.println(">>>" + f.get()); } System.out.println("----程序結(jié)束運(yùn)行----,程序運(yùn)行時(shí)間【" + (new Date().getTime() - beginTime.getTime()) + " 毫秒】"); } } class MyCallable implements Callable
上述就是小編為大家分享的java中怎么利用多線程批量執(zhí)行任務(wù)了,如果剛好有類(lèi)似的疑惑,不妨參照上述分析進(jìn)行理解。如果想知道更多相關(guān)知識(shí),歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。