中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

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
雅安市| 固原市| 平罗县| 方城县| 花垣县| 凤阳县| 响水县| 平安县| 许昌市| 灌南县| 和田市| 浏阳市| 金平| 郸城县| 邯郸县| 尉氏县| 石景山区| 新郑市| 同仁县| 大港区| 永善县| 西城区| 阿荣旗| 安阳县| 无锡市| 日照市| 民权县| 汤原县| 富锦市| 普兰县| 六枝特区| 清涧县| 柘城县| 天台县| 青州市| 桦甸市| 基隆市| 桐柏县| 大兴区| 永泰县| 凤山市|