mirrors/Odin
1
0
Fork 0
mirror of https://github.com/odin-lang/Odin.git synced 2025-12-30 01:44:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add the permanent and temporary arenas directly on the Thread

Browse Source
This commit is contained in:
gingerBill
2024-07-15 01:05:29 +01:00
parent c64702ae5a
commit a8f84c87ae
3 changed files with 80 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/threading.cpp
View File

@@ -70,6 +70,9 @@ struct Thread {
struct TaskQueue queue;
struct ThreadPool *pool;
struct Arena *permanent_arena;
struct Arena *temporary_arena;
};
typedef std::atomic<i32> Futex;
@@ -560,18 +563,20 @@ gb_internal void *internal_thread_proc(void *arg) {
}
#endif
TaskRingBuffer *task_ring_init(isize size) {
gb_internal TaskRingBuffer *task_ring_init(isize size) {
TaskRingBuffer *ring = gb_alloc_item(heap_allocator(), TaskRingBuffer);
ring->size = size;
ring->buffer = gb_alloc_array(heap_allocator(), WorkerTask, ring->size);
return ring;
}
void thread_queue_destroy(TaskQueue *q) {
gb_internal void thread_queue_destroy(TaskQueue *q) {
gb_free(heap_allocator(), (*q->ring).buffer);
gb_free(heap_allocator(), q->ring);
}
gb_internal void thread_init_arenas(Thread *t);
gb_internal void thread_init(ThreadPool *pool, Thread *t, isize idx) {
gb_zero_item(t);
#if defined(GB_SYSTEM_WINDOWS)
@@ -584,6 +589,8 @@ gb_internal void thread_init(ThreadPool *pool, Thread *t, isize idx) {
t->queue.ring = task_ring_init(1 << 14);
t->pool = pool;
t->idx = idx;
thread_init_arenas(t);
}
gb_internal void thread_init_and_start(ThreadPool *pool, Thread *t, isize idx) {