使用Runnable实现固定5个并发线程，线程结束后启动新线程如何实现？

算力阿峰

2026-10-4

实现方案

核心思路

使用JDK自带的java.util.concurrent.Semaphore（信号量）做并发数控制，指定5个许可，同一时间仅允许5个线程拿到许可执行业务逻辑，线程执行完毕后释放许可供后续线程使用，完全符合你要求的保留Runnable、保留new Thread(xxx).start()调用的限制。

改造后代码

import java.util.concurrent.Semaphore;
import java.math.BigDecimal;

// 你的原有类逻辑
public class Controller {
    // 省略logger定义等原有代码

    public void testThread() throws InterruptedException {
        // 定义信号量，许可数为5，保证同时最多5个线程运行
        Semaphore semaphore = new Semaphore(5);

        for (int i = 0; i < 20; i++) {
            BigDecimal threadNumber = new BigDecimal(i);

            Runnable r = () -> {
                try {
                    // 先获取许可，拿不到就阻塞等待
                    semaphore.acquire();
                    
                    logger.info("thread execution started.");
                    try {
                        Thread.sleep(1000 * 30);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    logger.info("thread execution ended.");
                } catch (InterruptedException e) {
                    e.printStackTrace();
                    Thread.currentThread().interrupt();
                } finally {
                    // 必须在finally里释放许可，避免异常导致许可泄漏
                    semaphore.release();
                }
            };
            // 完全保留你原有的线程启动调用方式
            new Thread(r, "thread-nb-" + threadNumber).start();
        }
    }
}