HSEARCH-4736 Try to offer to SimpleScheduledExecutor before offloadin…

…g the operation
hibernate · Feb 7, 2023 · e2f3d49 · e2f3d49
1 parent 6c7a987
commit e2f3d49
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/.../src/main/java/org/hibernate/search/engine/backend/work/execution/OperationSubmitter.java b/.../src/main/java/org/hibernate/search/engine/backend/work/execution/OperationSubmitter.java
@@ -127,7 +127,12 @@ public <T> void submitToQueue(BlockingQueue<? super T> queue, T element, Consume
 		@Override
 		public <T extends Runnable> void submitToExecutor(SimpleScheduledExecutor executor, T element,
 				Consumer<? super T> blockingRetryProducer) {
-			this.executor.accept( () -> blockingRetryProducer.accept( element ) );
+			try {
+				executor.offer( element );
+			}
+			catch (RejectedExecutionException e) {
+				this.executor.accept( () -> blockingRetryProducer.accept( element ) );
+			}
 		}
 	}