ed/Odin
1
0
Fork 0
mirror of https://github.com/Ed94/Odin.git synced 2026-08-06 15:48:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

Minimize use of mutex in Arena

Browse Source
This commit is contained in:
gingerBill
2024-07-15 01:15:00 +01:00
parent a8f84c87ae
commit cae8c1e94f
1 changed files with 17 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/common_memory.cpp
+15 -5
View File
@@ -32,6 +32,8 @@ gb_internal void virtual_memory_init(void) {
} }
gb_internal Thread *get_current_thread(void);
struct MemoryBlock { struct MemoryBlock {
MemoryBlock *prev; MemoryBlock *prev;
@@ -45,6 +47,7 @@ struct Arena {
isize minimum_block_size; isize minimum_block_size;
BlockingMutex mutex; BlockingMutex mutex;
isize temp_count; isize temp_count;
Thread * parent_thread;
}; };
enum { DEFAULT_MINIMUM_BLOCK_SIZE = 8ll*1024ll*1024ll }; enum { DEFAULT_MINIMUM_BLOCK_SIZE = 8ll*1024ll*1024ll };
@@ -70,6 +73,9 @@ gb_internal void thread_init_arenas(Thread *t) {
t->permanent_arena = gb_alloc_item(heap_allocator(), Arena); t->permanent_arena = gb_alloc_item(heap_allocator(), Arena);
t->temporary_arena = gb_alloc_item(heap_allocator(), Arena); t->temporary_arena = gb_alloc_item(heap_allocator(), Arena);
t->permanent_arena->parent_thread = t;
t->temporary_arena->parent_thread = t;
t->permanent_arena->minimum_block_size = DEFAULT_MINIMUM_BLOCK_SIZE; t->permanent_arena->minimum_block_size = DEFAULT_MINIMUM_BLOCK_SIZE;
t->temporary_arena->minimum_block_size = DEFAULT_MINIMUM_BLOCK_SIZE; t->temporary_arena->minimum_block_size = DEFAULT_MINIMUM_BLOCK_SIZE;
} }
@@ -77,7 +83,11 @@ gb_internal void thread_init_arenas(Thread *t) {
gb_internal void *arena_alloc(Arena *arena, isize min_size, isize alignment) { gb_internal void *arena_alloc(Arena *arena, isize min_size, isize alignment) {
GB_ASSERT(gb_is_power_of_two(alignment)); GB_ASSERT(gb_is_power_of_two(alignment));
if (arena->parent_thread == nullptr) {
mutex_lock(&arena->mutex); mutex_lock(&arena->mutex);
} else {
GB_ASSERT(arena->parent_thread == get_current_thread());
}
isize size = 0; isize size = 0;
if (arena->curr_block != nullptr) { if (arena->curr_block != nullptr) {
@@ -104,7 +114,9 @@ gb_internal void *arena_alloc(Arena *arena, isize min_size, isize alignment) {
curr_block->used += size; curr_block->used += size;
GB_ASSERT(curr_block->used <= curr_block->size); GB_ASSERT(curr_block->used <= curr_block->size);
if (arena->parent_thread == nullptr) {
mutex_unlock(&arena->mutex); mutex_unlock(&arena->mutex);
}
// NOTE(bill): memory will be zeroed by default due to virtual memory // NOTE(bill): memory will be zeroed by default due to virtual memory
return ptr; return ptr;
@@ -260,7 +272,7 @@ struct ArenaTemp {
ArenaTemp arena_temp_begin(Arena *arena) { ArenaTemp arena_temp_begin(Arena *arena) {
GB_ASSERT(arena); GB_ASSERT(arena);
MUTEX_GUARD(&arena->mutex); GB_ASSERT(arena->parent_thread == get_current_thread());
ArenaTemp temp = {}; ArenaTemp temp = {};
temp.arena = arena; temp.arena = arena;
@@ -275,7 +287,7 @@ ArenaTemp arena_temp_begin(Arena *arena) {
void arena_temp_end(ArenaTemp const &temp) { void arena_temp_end(ArenaTemp const &temp) {
GB_ASSERT(temp.arena); GB_ASSERT(temp.arena);
Arena *arena = temp.arena; Arena *arena = temp.arena;
MUTEX_GUARD(&arena->mutex); GB_ASSERT(arena->parent_thread == get_current_thread());
if (temp.block) { if (temp.block) {
bool memory_block_found = false; bool memory_block_found = false;
@@ -311,7 +323,7 @@ void arena_temp_end(ArenaTemp const &temp) {
void arena_temp_ignore(ArenaTemp const &temp) { void arena_temp_ignore(ArenaTemp const &temp) {
GB_ASSERT(temp.arena); GB_ASSERT(temp.arena);
Arena *arena = temp.arena; Arena *arena = temp.arena;
MUTEX_GUARD(&arena->mutex); GB_ASSERT(arena->parent_thread == get_current_thread());
GB_ASSERT_MSG(arena->temp_count > 0, "double-use of arena_temp_end"); GB_ASSERT_MSG(arena->temp_count > 0, "double-use of arena_temp_end");
arena->temp_count -= 1; arena->temp_count -= 1;
@@ -380,8 +392,6 @@ gb_global Arena default_permanent_arena = {nullptr, DEFAULT_MINIMUM_BLOCK_SIZE};
gb_global Arena default_temporary_arena = {nullptr, DEFAULT_MINIMUM_BLOCK_SIZE}; gb_global Arena default_temporary_arena = {nullptr, DEFAULT_MINIMUM_BLOCK_SIZE};
gb_internal Thread *get_current_thread(void);
gb_internal Arena *get_arena(ThreadArenaKind kind) { gb_internal Arena *get_arena(ThreadArenaKind kind) {
Thread *t = get_current_thread(); Thread *t = get_current_thread();
switch (kind) { switch (kind) {