1/**
2 * Copyright (c) 2006-2023 LOVE Development Team
3 *
4 * This software is provided 'as-is', without any express or implied
5 * warranty. In no event will the authors be held liable for any damages
6 * arising from the use of this software.
7 *
8 * Permission is granted to anyone to use this software for any purpose,
9 * including commercial applications, and to alter it and redistribute it
10 * freely, subject to the following restrictions:
11 *
12 * 1. The origin of this software must not be misrepresented; you must not
13 * claim that you wrote the original software. If you use this software
14 * in a product, an acknowledgment in the product documentation would be
15 * appreciated but is not required.
16 * 2. Altered source versions must be plainly marked as such, and must not be
17 * misrepresented as being the original software.
18 * 3. This notice may not be removed or altered from any source distribution.
19 **/
20
21#ifndef LOVE_THREAD_CHANNEL_H
22#define LOVE_THREAD_CHANNEL_H
23
24// STL
25#include <queue>
26
27// LOVE
28#include "common/Variant.h"
29#include "common/int.h"
30#include "threads.h"
31
32namespace love
33{
34namespace thread
35{
36
37class Channel : public love::Object
38{
39// FOR WRAPPER USE ONLY
40friend int w_Channel_performAtomic(lua_State *);
41
42public:
43
44 static love::Type type;
45
46 Channel();
47 ~Channel();
48
49 uint64 push(const Variant &var);
50 bool supply(const Variant &var); // blocking push
51 bool supply(const Variant &var, double timeout);
52 bool pop(Variant *var);
53 bool demand(Variant *var); // blocking pop
54 bool demand(Variant *var, double timeout); // blocking pop
55 bool peek(Variant *var);
56 int getCount() const;
57 bool hasRead(uint64 id) const;
58 void clear();
59
60private:
61
62 void lockMutex();
63 void unlockMutex();
64
65 MutexRef mutex;
66 ConditionalRef cond;
67 std::queue<Variant> queue;
68
69 uint64 sent;
70 uint64 received;
71
72}; // Channel
73
74} // thread
75} // love
76
77#endif // LOVE_THREAD_CHANNEL_H
78