diff options
author | Eike Stepper | 2013-04-16 05:11:52 +0000 |
---|---|---|
committer | Eike Stepper | 2013-04-16 05:18:12 +0000 |
commit | 7040c929c29a64bb427eb17a6f1a3051209f7774 (patch) | |
tree | 6e5d1996f8f5adaf54ca97ff13610c53b69f55f9 /plugins/org.eclipse.net4j.util | |
parent | d23bce5b998fc3aea7eddbfa9cfc1ebc803f37dc (diff) | |
download | cdo-7040c929c29a64bb427eb17a6f1a3051209f7774.tar.gz cdo-7040c929c29a64bb427eb17a6f1a3051209f7774.tar.xz cdo-7040c929c29a64bb427eb17a6f1a3051209f7774.zip |
[405761] InvalidationRunner threads are sometimes not properly stopped
https://bugs.eclipse.org/bugs/show_bug.cgi?id=405761
Diffstat (limited to 'plugins/org.eclipse.net4j.util')
-rw-r--r-- | plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/concurrent/QueueWorker.java | 11 |
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>(); |