在Java中限制线程数的多种方式

在Java中，限制线程数可以通过多种方式实现。以下是一些常用的方法：

1. 使用线程池（ThreadPoolExecutor）

使用java.util.concurrent.ThreadPoolExecutor可以有效地管理线程的数量。以下是一个简单的例子：

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadPoolExecutor;
public class Main {
    public static void main(String[] args) {
        int corePoolSize = 5;  // 核心线程数
        int maximumPoolSize = 10;  // 最大线程数
        long keepAliveTime = 5000;  // 空闲线程等待时间
        ExecutorService executor = new ThreadPoolExecutor(
            corePoolSize,
            maximumPoolSize,
            keepAliveTime,
            java.util.concurrent.TimeUnit.MILLISECONDS,
            new java.util.concurrent.LinkedBlockingQueue<Runnable>()
        );
        // 现在你可以提交任务给线程池
        for (int i = 0; i < 20; i++) {
            executor.submit(() -> {
                System.out.println("执行任务，线程名：" + Thread.currentThread().getName());
            });
        }
        // 关闭线程池
        executor.shutdown();
    }
}

在上面的代码中，线程池被限制为核心线程数为5，最大线程数为10。这意味着在任何给定时间，最多会有10个线程在执行任务。

2. 使用Executors工厂方法

Executors类提供了一些静态方法来创建线程池，这些方法也允许你限制线程数：

• Executors.newFixedThreadPool(int nThreads)：创建一个固定大小的线程池。

ExecutorService executor = Executors.newFixedThreadPool(10);  // 创建一个固定大小为10的线程池

3. 设置JVM参数

虽然这不是直接限制线程数的方法，但可以通过设置JVM参数来限制可以创建的线程总数：

• -XX:ThreadStackSize=size：设置线程栈的大小。
• -Xss<size>：设置每个线程的堆栈大小。
  通过限制线程栈的大小，间接限制了可以创建的线程数量，因为每个线程都会消耗一定的内存。

4. 自定义线程工厂

创建自定义的ThreadFactory，在创建线程时加入限制逻辑。

import java.util.concurrent.ThreadFactory;
import java.util.concurrent.atomic.AtomicInteger;
public class CustomThreadFactory implements ThreadFactory {
    private final AtomicInteger threadNumber = new AtomicInteger(1);
    private final int maxThreads;
    private int createdThreads = 0;
    public CustomThreadFactory(int maxThreads) {
        this.maxThreads = maxThreads;
    }
    @Override
    public Thread newThread(Runnable r) {
        if (createdThreads >= maxThreads) {
            throw new RuntimeException("线程数量已达上限");
        }
        Thread t = new Thread(r, "自定义线程-" + threadNumber.getAndIncrement());
        createdThreads++;
        return t;
    }
}

在创建线程池时使用这个自定义的线程工厂：

ExecutorService executor = Executors.newCachedThreadPool(new CustomThreadFactory(10));

以上方法可以根据具体的应用场景和需求选择使用。通常推荐使用线程池来管理线程，因为它提供了更好的性能和资源管理。