1 files changed, 11 insertions, 0 deletions
diff --git a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/concurrent/QueueWorker.java b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/concurrent/QueueWorker.java
index caec3355fa..1094072337 100644
--- a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/concurrent/QueueWorker.java
+++ b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/concurrent/QueueWorker.java
@@ -87,6 +87,10 @@ public abstract class QueueWorker<E> extends Worker
     {
       work(context, element);
     }
+    else
+    {
+      noWork(context);
+    }
   }
 
   /**
@@ -99,6 +103,13 @@ public abstract class QueueWorker<E> extends Worker
 
   protected abstract void work(WorkContext context, E element);
 
+  /**
+   * @since 3.3
+   */
+  protected void noWork(WorkContext context)
+  {
+  }
+
   protected BlockingQueue<E> createQueue()
   {
     return new LinkedBlockingQueue<E>();