ThreadPool.h
1.96 KB
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
#pragma once
#include "il2cpp-config.h"
struct Il2CppObject;
struct Il2CppDelegate;
struct Il2CppAsyncResult;
/* Keep in sync with System.IOOperation in mcs/class/System/System/IOSelector.cs */
enum Il2CppIOOperation
{
EVENT_IN = 1 << 0,
EVENT_OUT = 1 << 1,
EVENT_ERR = 1 << 2, /* not in managed */
};
namespace il2cpp
{
namespace vm
{
class LIBIL2CPP_CODEGEN_API ThreadPool
{
public:
struct Configuration
{
int minThreads;
int maxThreads;
int minAsyncIOThreads;
int maxAsyncIOThreads;
// These are read-only.
int availableThreads;
int availableAsyncIOThreads;
};
typedef struct
{
bool(*init)(int wakeup_pipe_fd);
void(*register_fd)(int fd, int events, bool is_new);
void(*remove_fd)(int fd);
int(*event_wait)(void(*callback)(int fd, int events, void* user_data), void* user_data);
} ThreadPoolIOBackend;
static void Initialize();
static void Shutdown();
/// On a thread, call the given delegate with 'params' as arguments. Upon completion,
/// call 'asyncCallback'.
static Il2CppAsyncResult* Queue(Il2CppDelegate* delegate, void** params, Il2CppDelegate* asyncCallback, Il2CppObject* state);
/// Wait for the execution of the given asynchronous call to have completed and return
/// the value returned by the delegate wrapped in the call (or null if the delegate has
/// a void return type).
/// NOTE: Any AsyncResult can only be waited on once! Repeated or concurrent calls to Wait() on the same AsyncResult
/// will throw InvalidOperationExceptions.
static Il2CppObject* Wait(Il2CppAsyncResult* asyncResult, void** outArgs);
static Configuration GetConfiguration();
static void SetConfiguration(const Configuration& configuration);
};
} /* namespace vm */
} /* namespace il2cpp */