java 新建线程如何控制并发数量

在Java中，要控制新建线程的并发数量，可以使用线程池（ExecutorService）来实现。线程池允许你限制同时运行的线程数量，从而有效地管理系统资源。以下是一个简单的示例，展示了如何使用ExecutorService来限制线程并发数量：

import java.util.concurrent.ExecutorService;
    
import java.util.concurrent.Executors;
    
import java.util.concurrent.TimeUnit;


public class ThreadPoolExample {

    public static void main(String[] args) {
    
        // 创建一个固定大小的线程池，最多同时运行3个线程
        ExecutorService executorService = Executors.newFixedThreadPool(3);
    

        // 提交任务到线程池
        for (int i = 0;
     i <
     10;
 i++) {
    
            executorService.submit(() ->
 {
    
                System.out.println("Task executed by thread: " + Thread.currentThread().getName());

                try {
    
                    // 模拟任务执行耗时
                    TimeUnit.SECONDS.sleep(2);

                }
 catch (InterruptedException e) {
    
                    e.printStackTrace();

                }

            }
    );

        }
    

        // 关闭线程池，不再接受新的任务
        executorService.shutdown();


        try {

            // 等待所有任务完成
            if (!executorService.awaitTermination(30, TimeUnit.SECONDS)) {
    
                executorService.shutdownNow();

            }

        }
 catch (InterruptedException e) {
    
            executorService.shutdownNow();

        }

    }

}
    

在这个示例中，我们创建了一个固定大小为3的线程池，然后提交了10个任务到线程池。线程池会自动分配任务给空闲的线程，并确保同时运行的线程数量不超过3个。当所有任务完成后，我们关闭线程池。

声明：本文内容由网友自发贡献，本站不承担相应法律责任。对本内容有异议或投诉，请联系2913721942#qq.com核实处理，我们将尽快回复您，谢谢合作！