Major Description
Wonder if it's a good idea to make the queue size to the "gremlinPool" configurable and thus bounded.
final BlockingQueue<Runnable> queue = new ArrayBlockingQueue<>(queueSize); gremlinExecutorService = new ThreadPoolExecutor(n, n, 0L, TimeUnit.MILLISECONDS, queue);
If the queue exceeded queueSize it would throw: RejectedExecutionException. This approach would also provide another metric to capture/report: queue.size().
Attachments
Issue Links
- depends upon
-
TINKERPOP-2245 Consolidate the executor for bytecode & string based client
-
- Closed
-