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
117
|
/*
==============================================================================
This file is part of the JUCE library.
Copyright (c) 2022 - Raw Material Software Limited
JUCE is an open source library subject to commercial or open-source
licensing.
By using JUCE, you agree to the terms of both the JUCE 7 End-User License
Agreement and JUCE Privacy Policy.
End User License Agreement: www.juce.com/juce-7-licence
Privacy Policy: www.juce.com/juce-privacy-policy
Or: You may also use this code under the terms of the GPL v3 (see
www.gnu.org/licenses).
JUCE IS PROVIDED "AS IS" WITHOUT ANY WARRANTY, AND ALL WARRANTIES, WHETHER
EXPRESSED OR IMPLIED, INCLUDING MERCHANTABILITY AND FITNESS FOR PURPOSE, ARE
DISCLAIMED.
==============================================================================
*/
#if JUCE_LINUX || JUCE_BSD
namespace juce
{
// Implemented in juce_linux_Messaging.cpp
bool dispatchNextMessageOnSystemQueue (bool returnIfNoPendingMessages);
/** @internal */
class MessageThread : public Thread
{
public:
MessageThread() : Thread ("JUCE Plugin Message Thread")
{
start();
}
~MessageThread() override
{
MessageManager::getInstance()->stopDispatchLoop();
stop();
}
void start()
{
startThread (Priority::high);
// Wait for setCurrentThreadAsMessageThread() and getInstance to be executed
// before leaving this method
threadInitialised.wait (10000);
}
void stop()
{
signalThreadShouldExit();
stopThread (-1);
}
bool isRunning() const noexcept { return isThreadRunning(); }
void run() override
{
MessageManager::getInstance()->setCurrentThreadAsMessageThread();
XWindowSystem::getInstance();
threadInitialised.signal();
while (! threadShouldExit())
{
if (! dispatchNextMessageOnSystemQueue (true))
Thread::sleep (1);
}
}
private:
WaitableEvent threadInitialised;
JUCE_DECLARE_NON_MOVEABLE (MessageThread)
JUCE_DECLARE_NON_COPYABLE_WITH_LEAK_DETECTOR (MessageThread)
};
//==============================================================================
/** @internal */
class HostDrivenEventLoop
{
public:
HostDrivenEventLoop()
{
messageThread->stop();
MessageManager::getInstance()->setCurrentThreadAsMessageThread();
}
void processPendingEvents()
{
MessageManager::getInstance()->setCurrentThreadAsMessageThread();
for (;;)
if (! dispatchNextMessageOnSystemQueue (true))
return;
}
~HostDrivenEventLoop()
{
messageThread->start();
}
private:
SharedResourcePointer<MessageThread> messageThread;
};
} // namespace juce
#endif
|
