Skip to content

Commit 892e0df

Browse files
committed
fix #879 - increase task queue size
1 parent 1434c5a commit 892e0df

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/java/com/marklogic/client/datamovement/impl/QueryBatcherImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -793,7 +793,7 @@ private class QueryThreadPoolExecutor extends ThreadPoolExecutor {
793793

794794
QueryThreadPoolExecutor(int threadCount, Object objectToNotifyFrom) {
795795
super(threadCount, threadCount, 0, TimeUnit.MILLISECONDS,
796-
new LinkedBlockingQueue<Runnable>(threadCount * 5), new ThreadPoolExecutor.CallerRunsPolicy());
796+
new LinkedBlockingQueue<Runnable>(threadCount * 50), new ThreadPoolExecutor.CallerRunsPolicy());
797797
this.objectToNotifyFrom = objectToNotifyFrom;
798798
}
799799

0 commit comments

Comments
 (0)