aboutsummaryrefslogtreecommitdiffstats
path: root/build/4coder_byp/custom/4coder_async_tasks.h
blob: f13ed92b9a8d020968c6cc7163a4236c74ad0e5b (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
/*
 * 4coder_async_tasks.cpp - Types for the custom layer asynchronous task system.
 */

// TOP

#if !defined(FCODER_ASYNC_TASKS_H)
#define FCODER_ASYNC_TASKS_H

typedef void Async_Task_Function_Type(struct Async_Context *actx, String_Const_u8 data);
typedef u64 Async_Task;

struct Async_Thread{
  struct Async_System *async_system;
  System_Thread thread;
  struct Async_Node *node;
  Async_Task task;
  b32 cancel_signal;
};

struct Async_Node{
  union{
    Async_Node *next;
    Node node;
  };
  Async_Task task;
  Async_Thread *thread;
  Async_Task_Function_Type *func;
  String_Const_u8 data;
};

struct Async_System{
  void *cmd_context;

  Heap node_heap;
  Arena node_arena;
  System_Mutex mutex;
  System_Condition_Variable cv;
  System_Condition_Variable join_cv;
  Async_Task task_id_counter;
  Async_Node *free_nodes;
  Node task_sent;
  i32 task_count;

  Async_Thread thread;
};

struct Async_Context{
  Application_Links *app;
  Async_Thread *thread;
};

#endif

// BOTTOM