Attachment #37024 for bug #64157

View | Details | Raw Unified | Return to bug 64157
Collapse All | Expand All





    public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory) {
        super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, threadFactory, new RejectHandler());
        prestartAllCoreThreads();
    }

    public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue) {
        super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, new RejectHandler());
        prestartAllCoreThreads();
    }

    public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory, boolean preStartMinSpareThreads) {
        super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, threadFactory, new RejectHandler());
        if (preStartMinSpareThreads) {
            prestartAllCoreThreads();
        }
    }

    public long getThreadRenewalDelay() {
        return threadRenewalDelay;

Return to bug 64157

Lines 75-87 Link Here

(-)java/org/apache/tomcat/util/threads/ThreadPoolExecutor.java (-1 / +7 lines)
75		75
76	public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory) {	76	public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory) {
77	super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, threadFactory, new RejectHandler());	77	super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, threadFactory, new RejectHandler());
78	prestartAllCoreThreads();
79	}	78	}
80		79
81	public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue) {	80	public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue) {
82	super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, new RejectHandler());	81	super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, new RejectHandler());
83	prestartAllCoreThreads();	82	prestartAllCoreThreads();
84	}	83	}
		84
		85	public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory, boolean preStartMinSpareThreads) {
		86	super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, threadFactory, new RejectHandler());
		87	if (preStartMinSpareThreads) {
		88	prestartAllCoreThreads();
		89	}
		90	}
85		91
86	public long getThreadRenewalDelay() {	92	public long getThreadRenewalDelay() {
87	return threadRenewalDelay;	93	return threadRenewalDelay;