spencer/findr
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

perf(findr): Pre-allocate thread-pool.

Browse Source
This commit is contained in:
Spencer Brower
2026-06-17 14:42:33 -04:00
parent 488a13004b
commit e5eac93071
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
walker.odin
View File

@@ -47,7 +47,7 @@ WalkerPool :: struct {
results_mutex: sync.Mutex, results_mutex: sync.Mutex,
active: i64, active: i64,
done: sync.One_Shot_Event, done: sync.One_Shot_Event,
threads: [dynamic]^thread.Thread, threads: []^thread.Thread,
opts: WalkOptions, opts: WalkOptions,
pattern_re: regex.Regular_Expression, pattern_re: regex.Regular_Expression,
has_pattern: bool, has_pattern: bool,
@@ -63,7 +63,7 @@ walk :: proc(roots: []string, results: ^[dynamic]string, opts: WalkOptions, thre
pool.queue = make([dynamic]WorkItem) pool.queue = make([dynamic]WorkItem)
pool.results = results pool.results = results
pool.active = i64(len(roots)) pool.active = i64(len(roots))
pool.threads = make([dynamic]^thread.Thread) pool.threads = make([]^thread.Thread, thread_count)
pool.all_contexts = make([dynamic]^GIContext) pool.all_contexts = make([dynamic]^GIContext)
pool.opts = opts pool.opts = opts
pool.exclude_gi = nil pool.exclude_gi = nil
@@ -100,7 +100,7 @@ walk :: proc(roots: []string, results: ^[dynamic]string, opts: WalkOptions, thre
t.data = rawptr(pool) t.data = rawptr(pool)
t.init_context = context t.init_context = context
thread.start(t) thread.start(t)
append(&pool.threads, t) pool.threads[i] = t
} }
sync.one_shot_event_wait(&pool.done) sync.one_shot_event_wait(&pool.done)