summaryrefslogtreecommitdiff
path: root/cpp/src/Ice/ThreadPool.h
diff options
context:
space:
mode:
authorBenoit Foucher <benoit@zeroc.com>2009-12-01 14:02:05 +0100
committerBenoit Foucher <benoit@zeroc.com>2009-12-01 14:02:05 +0100
commitcd63c3e37dde04051fb2f4631f788bed7b48937b (patch)
treeae2c581bd228ec42c6eb46bf83a88f1174623bac /cpp/src/Ice/ThreadPool.h
parentSLES RPM fixes (diff)
downloadice-cd63c3e37dde04051fb2f4631f788bed7b48937b.tar.bz2
ice-cd63c3e37dde04051fb2f4631f788bed7b48937b.tar.xz
ice-cd63c3e37dde04051fb2f4631f788bed7b48937b.zip
Added support for Ice::Dispatcher
Diffstat (limited to 'cpp/src/Ice/ThreadPool.h')
-rw-r--r--cpp/src/Ice/ThreadPool.h14
1 files changed, 14 insertions, 0 deletions
diff --git a/cpp/src/Ice/ThreadPool.h b/cpp/src/Ice/ThreadPool.h
index 9b7863643e2..0f1dd99fb71 100644
--- a/cpp/src/Ice/ThreadPool.h
+++ b/cpp/src/Ice/ThreadPool.h
@@ -16,6 +16,7 @@
#include <IceUtil/Thread.h>
#include <Ice/Config.h>
+#include <Ice/Dispatcher.h>
#include <Ice/ThreadPoolF.h>
#include <Ice/InstanceF.h>
#include <Ice/LoggerF.h>
@@ -162,6 +163,19 @@ public:
virtual void execute(ThreadPoolCurrent&) = 0;
};
+class DispatchWorkItem : public ThreadPoolWorkItem, public Ice::DispatcherCall
+{
+public:
+
+ DispatchWorkItem(const InstancePtr&);
+
+ virtual void execute(ThreadPoolCurrent&);
+
+private:
+
+ const InstancePtr _instance;
+};
+
class ThreadPoolWorkQueue : public EventHandler, public IceUtil::Mutex
{
public: