java中怎么利用多線程批量執(zhí)行任務(wù)

這期內(nèi)容當(dāng)中小編將會給大家?guī)碛嘘P(guān)java中怎么利用多線程批量執(zhí)行任務(wù)，文章內(nèi)容豐富且以專業(yè)的角度為大家分析和敘述，閱讀完這篇文章希望大家可以有所收獲。

import java.util.*;
import java.util.concurrent.*;

public class TestThread {

    public static void main(String[] args) throws ExecutionException, InterruptedException {
        System.out.println("----程序開始運行----");
        Date beginTime = new Date();

        // 創(chuàng)建一個線程池,容量為3
        ExecutorService pool = Executors.newFixedThreadPool(3);
        List<Future<String>> list = new LinkedList<>();
        // 創(chuàng)建10個有返回值的任務(wù)
        for (int i = 0; i < 10; i++) {
            Callable c = new MyCallable(i + " ");
            // 執(zhí)行任務(wù)并獲取Future對象
            Future f = pool.submit(c);
            list.add(f);
        }
        // 關(guān)閉線程池：會在所有任務(wù)執(zhí)行完成后關(guān)閉線程池，但并不會阻塞程序運行
        pool.shutdown();

        // 獲取所有并發(fā)任務(wù)的運行結(jié)果
        for (Future<String> f : list) {
            System.out.println(">>>" + f.get());
        }

        System.out.println("----程序結(jié)束運行----，程序運行時間【" + (new Date().getTime() - beginTime.getTime()) + " 毫秒】");
    }
}

class MyCallable implements Callable<Object> {
    private String taskNum;

    MyCallable(String taskNum) {
        this.taskNum = taskNum;
    }

    public Object call() throws Exception {
        Date beginTime = new Date();
        System.out.println(">>>" + taskNum + "任務(wù)開始");
        Thread.sleep(new Random().nextInt(5000));
        System.out.println(">>>" + taskNum + "任務(wù)結(jié)束");
        return taskNum + "任務(wù)耗時：" + (new Date().getTime() - beginTime.getTime());
    }
}

上述就是小編為大家分享的java中怎么利用多線程批量執(zhí)行任務(wù)了，如果剛好有類似的疑惑，不妨參照上述分析進(jìn)行理解。如果想知道更多相關(guān)知識，歡迎關(guān)注億速云行業(yè)資訊頻道。