Tenari
46 lines
1.6 KiB
C
46 lines
1.6 KiB
C
#include "all.h"
|
|
|
|
fn void mainThreadBaseEntryPoint(i32 argc, char **argv) {
|
|
Thread* async_threads = 0;
|
|
u64 lane_broadcast_val = 0;
|
|
{
|
|
u32 num_main_threads = 1;
|
|
u32 num_async_threads = 12;//TODO: os_get_system_info()->logical_processor_count;
|
|
u32 num_main_threads_clamped = Min(num_async_threads, num_main_threads);
|
|
num_async_threads -= num_main_threads_clamped;
|
|
String num_async_threads_string = cmd_line_string(&cmdline, str8_lit("async_thread_count"));
|
|
if(num_async_threads_string.size != 0)
|
|
{
|
|
try_u64_from_str8_c_rules(num_async_threads_string, &num_async_threads);
|
|
}
|
|
num_async_threads = Max(1, num_async_threads);
|
|
Barrier barrier = barrier_alloc(num_async_threads);
|
|
LaneCtx *lane_ctxs = push_array(scratch.arena, LaneCtx, num_async_threads);
|
|
async_threads_count = num_async_threads;
|
|
async_threads = push_array(scratch.arena, Thread, async_threads_count);
|
|
for EachIndex(idx, num_async_threads)
|
|
{
|
|
lane_ctxs[idx].lane_idx = idx;
|
|
lane_ctxs[idx].lane_count = async_threads_count;
|
|
lane_ctxs[idx].barrier = barrier;
|
|
lane_ctxs[idx].broadcast_memory = &lane_broadcast_val;
|
|
async_threads[idx] = thread_launch(async_thread_entry_point, &lane_ctxs[idx]);
|
|
}
|
|
}
|
|
|
|
//- rjf: call into entry point
|
|
entry_point(&cmdline);
|
|
|
|
//- rjf: join async threads
|
|
ins_atomic_u32_inc_eval(&global_async_exit);
|
|
cond_var_broadcast(async_tick_start_cond_var);
|
|
for EachIndex(idx, async_threads_count)
|
|
{
|
|
thread_join(async_threads[idx], max_U64);
|
|
}
|
|
}
|
|
|
|
fn void asyncThreadEntryPoint(void *params) {
|
|
}
|
|
|