Function run_cpu_thread

src/newcpu.cpp:5481–5604

}

static void run_cpu_thread(int (*f)(void *))
{
	int vp = 0;
	int intlev_prev = 0;
	int cck_cnt = 0;

	cpu_thread_active = 0;
	cpu_thread_tid = 0;
	cpu_thread_indirect_mode = 0xff;
	atomic_set(&cpu_thread_reset, 0);

	uae_sem_init(&cpu_in_sema, 0, 0);
	uae_sem_init(&cpu_out_sema, 0, 0);
	uae_sem_init(&cpu_wakeup_sema, 0, 0);

	if (!uae_start_thread(_T("cpu"), f, nullptr, &cpu_thread))
		return;
	cpu_thread_tid = uae_thread_get_id(cpu_thread);
	while (!cpu_thread_active) {
		sleep_millis(1);
	}

	while (!(regs.spcflags & SPCFLAG_MODE_CHANGE)) {
		if (regs.spcflags & SPCFLAG_CALLBACK) {
			unset_special(SPCFLAG_CALLBACK);
			device_call_main_thread_callbacks();
		}

		// Service any pending indirect memory request (lockless fast path)
		service_cpu_indirect_request();

		// Flush any batched register operations from the CPU thread
		cpu_thread_flush_register_batch();

		// Check for CPU reset request
		uae_u32 reset_val = __atomic_load_n(&cpu_thread_reset, __ATOMIC_ACQUIRE);
		if (reset_val & 1) {
			bool hardreset = reset_val & 2;
			bool keyboardreset = reset_val & 4;
			custom_reset(hardreset, keyboardreset);
			__atomic_store_n(&cpu_thread_reset, 0, __ATOMIC_RELEASE);
			uae_sem_post(&cpu_in_sema);
		}

		// Advance time - determine how many CCKs to run before re-checking IO
		// When idle (no pending request), run more cycles per iteration.
		// When a request just completed, re-check immediately after 1 cycle.
		int cycles_to_do;
		if (__atomic_load_n(&cpu_thread_indirect_mode, __ATOMIC_RELAXED) > 2) {
			cycles_to_do = currprefs.m68k_speed < 0 ? 256 : 128;
		} else {
			cycles_to_do = 1;
		}

		for (int i = 0; i < cycles_to_do; i++) {
			// Check for incoming IO request EVERY cycle for minimal latency
			if (i > 0 && service_cpu_indirect_request()) {
				// Serviced a request - flush register batch too while we're at it