Ease profiling

1 files changed, 9 insertions, 1 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 c6a159236f..caec3355fa 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
@@ -82,13 +82,21 @@ public abstract class QueueWorker<E> extends Worker
 
   private void doWork(WorkContext context) throws InterruptedException
   {
-    E element = queue.poll(pollMillis, TimeUnit.MILLISECONDS);
+    E element = pollQueue();
     if (element != null)
     {
       work(context, element);
     }
   }
 
+  /**
+   * Factored out for better profiling.
+   */
+  private E pollQueue() throws InterruptedException
+  {
+    return queue.poll(pollMillis, TimeUnit.MILLISECONDS);
+  }
+
   protected abstract void work(WorkContext context, E element);
 
   protected BlockingQueue<E> createQueue()