pluto-src 0.1.1+0.10.4

Sources of Pluto (Lua 5.4 dialect) and logic to build it.
Documentation 
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

#pragma once

#include "base.hpp"
#if !SOUP_WASM

#if SOUP_WINDOWS
#include <windows.h>
#else
#include <pthread.h>
#endif

#include <vector>

#include "Capture.hpp"
#include "TransientToken.hpp"
#include "UniquePtr.hpp"

NAMESPACE_SOUP
{
	// This class itself is not thread-safe. If you need multiple threads to access the same instance, use a mutex.
	class Thread
	{
	public:
		struct RunningData
		{
			void(*f)(Capture&&);
			Capture f_cap;
			TransientToken transient_token;
		};

#if SOUP_WINDOWS
		HANDLE handle = INVALID_HANDLE_VALUE;
#else
		pthread_t handle{};
		bool have_handle = false;
#endif
		TransientTokenRef running_ref{};

		explicit Thread() SOUP_EXCAL = default;
		explicit Thread(void(*f)(Capture&&), Capture&& cap = {});
		explicit Thread(const Thread& b) = delete;
		explicit Thread(Thread&& b) noexcept;
		void start(void(*f)(Capture&&), Capture&& cap = {});

		~Thread() noexcept { awaitCompletion(); }

#if SOUP_WINDOWS || SOUP_LINUX
		void setTimeCritical() noexcept;
#endif

		[[nodiscard]] bool isAttached() const noexcept;
		[[nodiscard]] bool isRunning() const noexcept { return running_ref.isValid(); }

		void awaitCompletion() noexcept;
		static void awaitCompletion(const std::vector<UniquePtr<Thread>>& threads) noexcept;

		void detach() noexcept;

	protected:
		void forget() noexcept;
	};
}

#endif