diff options
| author | Henning Baldersheim <balder@yahoo-inc.com> | 2019-09-30 17:16:54 +0200 |
|---|---|---|
| committer | Henning Baldersheim <balder@yahoo-inc.com> | 2019-09-30 17:16:54 +0200 |
| commit | 3300afc531fc2862d1646277aedb44e9033f290f (patch) | |
| tree | 55749a61c91f5ff719d1d66fc81da1bf8472645d /docproc | |
| parent | 34dd2f7153f4a6cd1ea0b802f28cde8abdd48707 (diff) | |
Define unlimited threads to 2048 instead of 8192.
Diffstat (limited to 'docproc')
| -rw-r--r-- | docproc/src/main/java/com/yahoo/docproc/jdisc/DocprocThreadPoolExecutor.java | 2 | ||||
| -rw-r--r-- | docproc/src/main/resources/configdefinitions/docproc.def | 2 |
2 files changed, 3 insertions, 1 deletions
diff --git a/docproc/src/main/java/com/yahoo/docproc/jdisc/DocprocThreadPoolExecutor.java b/docproc/src/main/java/com/yahoo/docproc/jdisc/DocprocThreadPoolExecutor.java index 23ab73c7f1d..e1a902c8d5c 100644 --- a/docproc/src/main/java/com/yahoo/docproc/jdisc/DocprocThreadPoolExecutor.java +++ b/docproc/src/main/java/com/yahoo/docproc/jdisc/DocprocThreadPoolExecutor.java @@ -20,7 +20,7 @@ public class DocprocThreadPoolExecutor extends ThreadPoolExecutor { public DocprocThreadPoolExecutor(int maxNumThreads, BlockingQueue<Runnable> queue, DocprocThreadManager threadMgr) { super((maxNumThreads > 0) ? maxNumThreads : Runtime.getRuntime().availableProcessors(), - (maxNumThreads > 0) ? maxNumThreads : 8192, + (maxNumThreads > 0) ? maxNumThreads : 2048, 1, TimeUnit.SECONDS, queue, new DaemonThreadFactory("docproc-")); diff --git a/docproc/src/main/resources/configdefinitions/docproc.def b/docproc/src/main/resources/configdefinitions/docproc.def index 645fbcce1b7..53f5c2de21f 100644 --- a/docproc/src/main/resources/configdefinitions/docproc.def +++ b/docproc/src/main/resources/configdefinitions/docproc.def @@ -6,7 +6,9 @@ namespace=config.docproc # 0 Gives a PriorityQueue # Negative values gives a SynchronousQueue if numthreads <= 0 (which increases thread pool size as required), # otherwise a LinkedBlockingQueue +# Depreacated and a noop maxqueuetimems int default=-1 # The number of threads in the DocprocHandler worker thread pool +# Default is number of cpu's, but is dynamic up to 2048 numthreads int default=-1 |