X-Git-Url: http://git.xonotic.org/?a=blobdiff_plain;f=thread.h;h=a9a00658bfc97f19ff7e715c9e91666c22042302;hb=27b8e67dec8c8084ba38ed8201dc54ccd46fdb23;hp=85e5200140eb73d522a53c2ebcd24f5b8511dfbf;hpb=ed17b0043966690a70381680a95b0e51891efa40;p=xonotic%2Fdarkplaces.git diff --git a/thread.h b/thread.h index 85e52001..a9a00658 100644 --- a/thread.h +++ b/thread.h @@ -1,4 +1,5 @@ #ifndef THREAD_H +#define THREAD_H // enable Sys_PrintfToTerminal calls on nearly every threading call //#define THREADDEBUG @@ -58,54 +59,4 @@ qboolean _Thread_AtomicTryLock(Thread_SpinLock *lock, const char *filename, int void _Thread_AtomicLock(Thread_SpinLock *lock, const char *filename, int fileline); void _Thread_AtomicUnlock(Thread_SpinLock *lock, const char *filename, int fileline); -typedef struct taskqueue_task_s -{ - // doubly linked list - struct taskqueue_task_s * volatile prev; - struct taskqueue_task_s * volatile next; - - // if not NULL, this task must be done before this one will dequeue (faster than simply Yielding immediately) - struct taskqueue_task_s *preceding; - - // see TaskQueue_IsDone() to use proper atomics to poll done status - volatile int started; - volatile int done; - - // function to call, and parameters for it to use - void(*func)(struct taskqueue_task_s *task); - void *p[4]; - size_t i[4]; - - // stats: - unsigned int yieldcount; // number of times this task has been requeued -} -taskqueue_task_t; - -// immediately execute any pending tasks if threading is disabled (or if force is true) -// TRY NOT TO USE THIS IF POSSIBLE - poll task->done instead. -void TaskQueue_Execute(qboolean force); - -// queue the tasks to be executed, or executes them immediately if threading is disabled. -void TaskQueue_Enqueue(int numtasks, taskqueue_task_t *tasks); - -// if the task can not be completed due yet to preconditions, just enqueue it again... -void TaskQueue_Yield(taskqueue_task_t *t); - -// polls for status of task and returns the result immediately - use this instead of checking ->done directly, as this uses atomics -qboolean TaskQueue_IsDone(taskqueue_task_t *t); - -// polls for status of task and waits for it to be done -void TaskQueue_WaitForTaskDone(taskqueue_task_t *t); - -// updates thread count based on the cvar. -void TaskQueue_Frame(qboolean shutdown); - -// convenience function for setting up a task structure. Does not do the Enqueue, just fills in the struct. -void TaskQueue_Setup(taskqueue_task_t *t, taskqueue_task_t *preceding, void(*func)(taskqueue_task_t *), size_t i0, size_t i1, void *p0, void *p1); - -// general purpose tasks -// t->i[0] = number of tasks in array -// t->p[0] = array of taskqueue_task_t to check -void TaskQueue_Task_CheckTasksDone(taskqueue_task_t *t); - #endif