diff --git a/engine/src/main/java/org/hibernate/search/engine/backend/work/execution/OperationSubmitter.java b/engine/src/main/java/org/hibernate/search/engine/backend/work/execution/OperationSubmitter.java
index c3c9129bd34..b5dbbc26255 100644
--- a/engine/src/main/java/org/hibernate/search/engine/backend/work/execution/OperationSubmitter.java
+++ b/engine/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 ) );
+			}
 		}
 	}