blob: fc20a04fe82f716478ffca8c4172178fc1200704 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
|
//
// ActiveDispatcher.cpp
//
// Library: Foundation
// Package: Threading
// Module: ActiveObjects
//
// Copyright (c) 2006-2007, Applied Informatics Software Engineering GmbH.
// and Contributors.
//
// SPDX-License-Identifier: BSL-1.0
//
#include "Poco/ActiveDispatcher.h"
#include "Poco/Notification.h"
#include "Poco/AutoPtr.h"
namespace Poco {
namespace
{
class MethodNotification: public Notification
{
public:
MethodNotification(ActiveRunnableBase::Ptr pRunnable):
_pRunnable(pRunnable)
{
}
ActiveRunnableBase::Ptr runnable() const
{
return _pRunnable;
}
private:
ActiveRunnableBase::Ptr _pRunnable;
};
class StopNotification: public Notification
{
};
}
ActiveDispatcher::ActiveDispatcher()
{
}
ActiveDispatcher::ActiveDispatcher(Thread::Priority prio)
{
_thread.setPriority(prio);
}
ActiveDispatcher::~ActiveDispatcher()
{
try
{
stop();
}
catch (...)
{
}
}
void ActiveDispatcher::start(ActiveRunnableBase::Ptr pRunnable)
{
poco_check_ptr (pRunnable);
if (!_thread.isRunning())
{
_thread.start(*this);
}
_queue.enqueueNotification(new MethodNotification(pRunnable));
}
void ActiveDispatcher::cancel()
{
_queue.clear();
}
void ActiveDispatcher::run()
{
AutoPtr<Notification> pNf = _queue.waitDequeueNotification();
while (pNf && !dynamic_cast<StopNotification*>(pNf.get()))
{
MethodNotification* pMethodNf = dynamic_cast<MethodNotification*>(pNf.get());
poco_check_ptr (pMethodNf);
ActiveRunnableBase::Ptr pRunnable = pMethodNf->runnable();
pRunnable->duplicate(); // run will release
pRunnable->run();
pRunnable = 0;
pNf = 0;
pNf = _queue.waitDequeueNotification();
}
}
void ActiveDispatcher::stop()
{
_queue.clear();
_queue.wakeUpAll();
_queue.enqueueNotification(new StopNotification);
_thread.join();
}
} // namespace Poco
|
