Method ThreadStartFunc

source/task_scheduler.cpp:52–90

};

FTL_THREAD_FUNC_RETURN_TYPE TaskScheduler::ThreadStartFunc(void *const arg) {
	auto *const threadArgs = reinterpret_cast<ThreadStartArgs *>(arg);
	TaskScheduler *taskScheduler = threadArgs->Scheduler;
	unsigned const index = threadArgs->ThreadIndex;
	SetCurrentThreadAffinity(index);
	// Clean up
	delete threadArgs;

	// Spin wait until everything is initialized
	while (!taskScheduler->m_initialized.load(std::memory_order_acquire)) {
		// Spin
		FTL_PAUSE();
	}

	// Execute user thread start callback, if set
	const EventCallbacks &callbacks = taskScheduler->m_callbacks;
	if (callbacks.OnWorkerThreadStarted != nullptr) {
		callbacks.OnWorkerThreadStarted(callbacks.Context, index);
	}

	// Get a free fiber to switch to
	unsigned const freeFiberIndex = taskScheduler->GetNextFreeFiberIndex();

	// Initialize tls
	taskScheduler->m_tls[index].CurrentFiberIndex = freeFiberIndex;
	// Switch
	taskScheduler->m_tls[index].ThreadFiber.SwitchToFiber(&taskScheduler->m_fibers[freeFiberIndex]);

	// And we've returned

	// Execute user thread end callback, if set
	if (callbacks.OnWorkerThreadEnded != nullptr) {
		callbacks.OnWorkerThreadEnded(callbacks.Context, index);
	}

	// Cleanup and shutdown
	EndCurrentThread();
	FTL_THREAD_FUNC_END;
}

// This Task is never used directly
// However, a function pointer to it is the signal that the task is a Ready fiber, not a "real" task