Java 线程池中怎么获取线程池队列大小-java教程-PHP中文网

在 java 中，获取线程池队列大小最直接的方法是使用 java.util.concurrent.threadpoolexecutor 提供的 getqueue().size()。该方法返回当前队列中等待执行的任务数量。需要注意的是，只有当线程池实例是 threadpoolexecutor 类型时才能直接调用此方法；如果使用的是 java.util.concurrent.executorservice 接口，则需要将其强转为 threadpoolexecutor。

Java 线程池中怎么获取线程池队列大小

如何从 ExecutorService 获取队列大小

要获取队列大小，必须将 ExecutorService 强转为 ThreadPoolExecutor，然后调用 getQueue().size()。如果传入的是其他实现类（如 ScheduledThreadPoolExecutor），则需根据具体子类调整强转类型或调用对应方法。

Java 线程池中怎么获取线程池队列大小

import java.util.concurrent.*;

public class QueueSizeExample {
    public static void main(String[] args) {
        // 创建固定大小线程池
        ThreadPoolExecutor executor = (ThreadPoolExecutor) Executors.newFixedThreadPool(2);
        
        // 提交任务以填充队列
        for (int i = 0; i  {
                try { Thread.sleep(1000); } catch (InterruptedException e) {}
            });
        }
        
        // 获取队列大小
        int queueSize = executor.getQueue().size();
        System.out.println("Current queue size: " + queueSize);
        
        executor.shutdown();
    }
}

预期输出：
Current queue size: 3
说明：线程池核心大小为 2，提交 5 个任务后，2 个立即执行，剩余 3 个进入队列。

队列满时如何处理新任务

当队列已满且线程数达到最大值时，新提交的任务会触发拒绝策略。可通过 getQueue().remainingCapacity() 检查剩余容量，或通过 getActiveCount() 和 getPoolSize() 判断线程是否饱和。若需自定义行为，可设置 RejectedExecutionHandler。

javascript-typescript-typescript-scaffold

你是 TypeScript 项目架构专家，专注于脚手架搭建生产就绪的 Node.js 和前端应用。生成包含现代工具链（pnpm、Vite、Next.js）、类型

下载

Java 线程池中怎么获取线程池队列大小

import java.util.concurrent.*;

public class RejectionExample {
    public static void main(String[] args) {
        ThreadPoolExecutor executor = new ThreadPoolExecutor(
            2, 2, 0L, TimeUnit.MILLISECONDS,
            new LinkedBlockingQueue(2),
            new ThreadPoolExecutor.CallerRunsPolicy()
        );
        
        // 提交 6 个任务：2 个线程 + 2 个队列 + 2 个触发拒绝
        for (int i = 0; i  {
                System.out.println("Task " + taskId + " running on " + Thread.currentThread().getName());
            });
        }
        
        executor.shutdown();
    }
}

预期输出：
Task 0 running on pool-1-thread-1
Task 1 running on pool-1-thread-2
Task 2 running on pool-1-thread-1
Task 3 running on pool-1-thread-2
Task 4 running on main
Task 5 running on main
说明：前 4 个任务由线程池处理，后 2 个因队列满且线程饱和，由调用者线程（main）执行。