Java – 同時に実行できるスレッドの上限を確認する方法

import java.util.concurrent.Executors;
import java.util.concurrent.ThreadPoolExecutor;
public class App {
    public static void main(String[] args) {
        // 利用可能なプロセッサの数を取得
        int availableProcessors = Runtime.getRuntime().availableProcessors();
        System.out.println("利用可能なプロセッサの数: " + availableProcessors);
        // スレッドプールを作成
        ThreadPoolExecutor executor = (ThreadPoolExecutor) Executors.newFixedThreadPool(availableProcessors);
        // スレッドプールの最大スレッド数を表示
        System.out.println("スレッドプールの最大スレッド数: " + executor.getMaximumPoolSize());
        // スレッドプールをシャットダウン
        executor.shutdown();
    }
}

利用可能なプロセッサの数: 32
スレッドプールの最大スレッド数: 32

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class App {
    public static void main(String[] args) {
        // スレッドプールを作成(最大スレッド数は4)
        ExecutorService executor = Executors.newFixedThreadPool(4);
        // タスクを実行
        for (int i = 0; i < 10; i++) {
            final int taskId = i;
            executor.submit(() -> {
                System.out.println("タスク " + taskId + " が実行中");
                try {
                    // タスクの処理を模擬するためにスリープ
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                }
                System.out.println("タスク " + taskId + " が完了");
            });
        }
        // スレッドプールをシャットダウン
        executor.shutdown();
    }
}

タスク 0 が実行中
タスク 1 が実行中
タスク 2 が実行中
タスク 3 が実行中
タスク 0 が完了
タスク 1 が完了
タスク 2 が完了
タスク 3 が完了
タスク 4 が実行中
タスク 5 が実行中
タスク 6 が実行中
タスク 7 が実行中
タスク 4 が完了
タスク 5 が完了
タスク 6 が完了
タスク 7 が完了
タスク 8 が実行中
タスク 9 が実行中
タスク 8 が完了
タスク 9 が完了

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class App {
    public static void main(String[] args) {
        // CPUバウンドタスク用のスレッドプール(4スレッド)
        ExecutorService cpuBoundExecutor = Executors.newFixedThreadPool(4);
        
        // I/Oバウンドタスク用のスレッドプール(8スレッド)
        ExecutorService ioBoundExecutor = Executors.newFixedThreadPool(8);
        // CPUバウンドタスクの実行
        for (int i = 0; i < 4; i++) {
            cpuBoundExecutor.submit(() -> {
                long sum = 0;
                for (int j = 0; j < 1_000_000; j++) {
                    sum += j; // 計算処理
                }
                System.out.println("CPUバウンドタスク完了");
            });
        }
        // I/Oバウンドタスクの実行
        for (int i = 0; i < 8; i++) {
            ioBoundExecutor.submit(() -> {
                try {
                    // I/O処理を模擬するためにスリープ
                    Thread.sleep(2000);
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                }
                System.out.println("I/Oバウンドタスク完了");
            });
        }
        // スレッドプールをシャットダウン
        cpuBoundExecutor.shutdown();
        ioBoundExecutor.shutdown();
    }
}

CPUバウンドタスク完了
CPUバウンドタスク完了
CPUバウンドタスク完了
CPUバウンドタスク完了
I/Oバウンドタスク完了
I/Oバウンドタスク完了
I/Oバウンドタスク完了
I/Oバウンドタスク完了
I/Oバウンドタスク完了
I/Oバウンドタスク完了
I/Oバウンドタスク完了
I/Oバウンドタスク完了

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class App {
    public static void main(String[] args) {
        // スレッドプールを作成
        ExecutorService executor = Executors.newFixedThreadPool(4);
        // タスクを実行
        for (int i = 0; i < 10; i++) {
            final int taskId = i;
            executor.submit(() -> {
                try {
                    System.out.println("タスク " + taskId + " が開始されました。");
                    // タスクの処理を模擬するためにスリープ
                    Thread.sleep(1000);
                    System.out.println("タスク " + taskId + " が完了しました。");
                } catch (InterruptedException e) {
                    System.err.println("タスク " + taskId + " が中断されました。");
                    Thread.currentThread().interrupt();
                }
            });
        }
        // スレッドプールをシャットダウン
        executor.shutdown();
    }
}

タスク 0 が開始されました。
タスク 1 が開始されました。
タスク 2 が開始されました。
タスク 3 が開始されました。
タスク 0 が完了しました。
タスク 1 が完了しました。
タスク 2 が完了しました。
タスク 3 が完了しました。
タスク 4 が開始されました。
タスク 5 が開始されました。
タスク 6 が開始されました。
タスク 7 が開始されました。
タスク 4 が完了しました。
タスク 5 が完了しました。
タスク 6 が完了しました。
タスク 7 が完了しました。
タスク 8 が開始されました。
タスク 9 が開始されました。
タスク 8 が完了しました。
タスク 9 が完了しました。

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class App {
    public static void main(String[] args) {
        // スレッドプールを作成(最大スレッド数は4)
        ExecutorService executor = Executors.newFixedThreadPool(4);
        // タスクを小分けにして実行
        for (int i = 0; i < 10; i++) {
            final int taskId = i;
            executor.submit(() -> {
                System.out.println("タスク " + taskId + " が開始されました。");
                try {
                    // タスクの処理を模擬するためにスリープ
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                }
                System.out.println("タスク " + taskId + " が完了しました。");
            });
        }
        // スレッドプールをシャットダウン
        executor.shutdown();
    }
}

タスク 0 が開始されました。
タスク 1 が開始されました。
タスク 2 が開始されました。
タスク 3 が開始されました。
タスク 0 が完了しました。
タスク 1 が完了しました。
タスク 2 が完了しました。
タスク 3 が完了しました。
タスク 4 が開始されました。
タスク 5 が開始されました。
タスク 6 が開始されました。
タスク 7 が開始されました。
タスク 4 が完了しました。
タスク 5 が完了しました。
タスク 6 が完了しました。
タスク 7 が完了しました。
タスク 8 が開始されました。
タスク 9 が開始されました。
タスク 8 が完了しました。
タスク 9 が完了しました。