亚洲激情专区-91九色丨porny丨老师-久久久久久久女国产乱让韩-国产精品午夜小视频观看

溫馨提示×

java多線程怎么實現任務分配

小樊
85
2024-09-02 05:21:34
欄目: 編程語言

在Java中,可以使用線程池(ExecutorService)和Callable接口來實現多線程任務分配。以下是一個簡單的示例:

  1. 首先,創建一個實現Callable接口的類,用于定義任務:
import java.util.concurrent.Callable;

public class Task implements Callable<String> {
    private int taskId;

    public Task(int taskId) {
        this.taskId = taskId;
    }

    @Override
    public String call() throws Exception {
        // 在這里執行任務
        System.out.println("Task " + taskId + " is running by " + Thread.currentThread().getName());
        return "Task " + taskId + " completed";
    }
}
  1. 然后,在主程序中創建一個線程池,將任務提交給線程池執行:
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.*;

public class Main {
    public static void main(String[] args) {
        // 創建一個固定大小的線程池
        ExecutorService executorService = Executors.newFixedThreadPool(3);

        // 創建任務列表
        List<Future<String>> futures = new ArrayList<>();

        // 提交任務
        for (int i = 0; i < 5; i++) {
            Task task = new Task(i);
            Future<String> future = executorService.submit(task);
            futures.add(future);
        }

        // 獲取任務結果
        for (Future<String> future : futures) {
            try {
                System.out.println(future.get());
            } catch (InterruptedException | ExecutionException e) {
                e.printStackTrace();
            }
        }

        // 關閉線程池
        executorService.shutdown();
    }
}

在這個示例中,我們創建了一個固定大小為3的線程池,并提交了5個任務。線程池會自動分配任務給空閑的線程,并在任務完成后返回結果。最后,我們關閉線程池以釋放資源。

0
安徽省| 屏东市| 稻城县| 西华县| 恩施市| 静乐县| 托克逊县| 普宁市| 铜梁县| 汨罗市| 宝山区| 南溪县| 桐乡市| 涪陵区| 酒泉市| 乐清市| 汝城县| 江油市| 克拉玛依市| 张家口市| 阜宁县| 万盛区| 华阴市| 甘孜| 高台县| 兴文县| 松滋市| 江西省| 金华市| 平陆县| 阿坝| 天门市| 沂南县| 元氏县| 囊谦县| 万源市| 诸暨市| 勐海县| 宁武县| 布拖县| 庆城县|