/home/mrjunejune/zenbu: seobeo/s

annotate seobeo/s_worker.c @ 273:e02e2036ef84 default tip

add Layer 2 JRPG component system Add reusable content and window modals, an isolated component sandbox, shared cyberpunk scroll areas, production-safe cache freshness, and server-rendered JRPG panel state. Co-authored-by: Copilot <[email protected]>

author	MrJuneJune <me@mrjunejune.com>
date	Sat, 08 Aug 2026 02:08:08 -0700
parents	745fd127b2a1
children

rev	line source
250 745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	1 #include "seobeo/seobeo_worker.h"
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	2
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	3 #include <pthread.h>
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	4 #include <stdlib.h>
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	5 #include <string.h>
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	6
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	7 typedef struct {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	8 Seobeo_Work_Function function;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	9 void *p_context;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	10 Seobeo_Work_Cleanup cleanup;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	11 } Seobeo_Work_Item;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	12
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	13 struct Seobeo_Thread {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	14 pthread_t thread;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	15 Seobeo_Work_Item item;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	16 };
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	17
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	18 struct Seobeo_Worker_Pool {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	19 pthread_t *p_threads;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	20 Seobeo_Work_Item *p_queue;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	21 uint32 worker_count;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	22 uint32 queue_capacity;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	23 uint32 queue_head;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	24 uint32 queue_count;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	25 uint32 active_count;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	26 uint32 cleanup_count;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	27 boolean accepting;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	28 boolean stopping;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	29 boolean drain;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	30 boolean shutdown_started;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	31 boolean joined;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	32 pthread_mutex_t mutex;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	33 pthread_cond_t work_available;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	34 pthread_cond_t idle;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	35 };
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	36
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	37 static _Thread_local Seobeo_Worker_Pool *g_current_worker_pool = NULL;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	38
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	39 static void Seobeo_Work_Item_Run(Seobeo_Work_Item *p_item)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	40 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	41 p_item->function(p_item->p_context);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	42 if (p_item->cleanup)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	43 p_item->cleanup(p_item->p_context);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	44 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	45
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	46 static void Seobeo_Thread_Run(void p_argument)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	47 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	48 Seobeo_Thread *p_thread = p_argument;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	49 Seobeo_Work_Item_Run(&p_thread->item);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	50 return NULL;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	51 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	52
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	53 Seobeo_Thread *Seobeo_Thread_Start(
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	54 Seobeo_Work_Function function,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	55 void *p_context,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	56 Seobeo_Work_Cleanup cleanup)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	57 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	58 if (!function)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	59 return NULL;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	60
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	61 Seobeo_Thread p_thread = calloc(1, sizeof(p_thread));
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	62 if (!p_thread)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	63 return NULL;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	64 p_thread->item = (Seobeo_Work_Item){
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	65 .function = function,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	66 .p_context = p_context,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	67 .cleanup = cleanup,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	68 };
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	69 if (pthread_create(
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	70 &p_thread->thread,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	71 NULL,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	72 Seobeo_Thread_Run,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	73 p_thread) != 0)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	74 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	75 free(p_thread);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	76 return NULL;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	77 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	78 return p_thread;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	79 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	80
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	81 Seobeo_Worker_Result Seobeo_Thread_Join(Seobeo_Thread *p_thread)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	82 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	83 if (!p_thread)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	84 return SEOBEO_WORKER_INVALID_ARGUMENT;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	85 if (pthread_equal(pthread_self(), p_thread->thread))
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	86 return SEOBEO_WORKER_INVALID_ARGUMENT;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	87
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	88 int result = pthread_join(p_thread->thread, NULL);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	89 free(p_thread);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	90 return result == 0
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	91 ? SEOBEO_WORKER_OK
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	92 : SEOBEO_WORKER_THREAD_ERROR;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	93 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	94
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	95 static void Seobeo_Thread_Run_Detached(void p_argument)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	96 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	97 Seobeo_Work_Item *p_item = p_argument;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	98 Seobeo_Work_Item_Run(p_item);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	99 free(p_item);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	100 return NULL;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	101 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	102
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	103 Seobeo_Worker_Result Seobeo_Thread_Start_Detached(
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	104 Seobeo_Work_Function function,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	105 void *p_context,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	106 Seobeo_Work_Cleanup cleanup)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	107 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	108 if (!function)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	109 return SEOBEO_WORKER_INVALID_ARGUMENT;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	110
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	111 Seobeo_Work_Item p_item = malloc(sizeof(p_item));
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	112 if (!p_item)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	113 return SEOBEO_WORKER_OUT_OF_MEMORY;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	114 *p_item = (Seobeo_Work_Item){
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	115 .function = function,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	116 .p_context = p_context,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	117 .cleanup = cleanup,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	118 };
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	119
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	120 pthread_attr_t attributes;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	121 if (pthread_attr_init(&attributes) != 0)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	122 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	123 free(p_item);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	124 return SEOBEO_WORKER_THREAD_ERROR;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	125 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	126 int result = pthread_attr_setdetachstate(
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	127 &attributes,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	128 PTHREAD_CREATE_DETACHED);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	129 pthread_t thread;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	130 if (result == 0)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	131 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	132 result = pthread_create(
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	133 &thread,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	134 &attributes,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	135 Seobeo_Thread_Run_Detached,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	136 p_item);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	137 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	138 pthread_attr_destroy(&attributes);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	139 if (result != 0)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	140 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	141 free(p_item);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	142 return SEOBEO_WORKER_THREAD_ERROR;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	143 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	144 return SEOBEO_WORKER_OK;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	145 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	146
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	147 uint64 Seobeo_Thread_Current_Id(void)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	148 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	149 pthread_t thread = pthread_self();
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	150 const uint8 p_bytes = (const uint8 )&thread;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	151 uint64 hash = 1469598103934665603ULL;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	152 for (size_t i = 0; i < sizeof(thread); i++)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	153 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	154 hash ^= p_bytes[i];
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	155 hash *= 1099511628211ULL;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	156 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	157 return hash;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	158 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	159
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	160 static boolean Seobeo_Worker_Pool_Is_Current_Thread(
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	161 Seobeo_Worker_Pool *p_pool)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	162 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	163 pthread_t current = pthread_self();
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	164 for (uint32 i = 0; i < p_pool->worker_count; i++)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	165 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	166 if (pthread_equal(current, p_pool->p_threads[i]))
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	167 return TRUE;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	168 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	169 return FALSE;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	170 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	171
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	172 static void Seobeo_Worker_Pool_Run(void p_argument)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	173 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	174 Seobeo_Worker_Pool *p_pool = p_argument;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	175 while (TRUE)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	176 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	177 pthread_mutex_lock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	178 while (p_pool->queue_count == 0 && !p_pool->stopping)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	179 pthread_cond_wait(&p_pool->work_available, &p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	180
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	181 if (p_pool->stopping &&
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	182 (!p_pool->drain \|\| p_pool->queue_count == 0))
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	183 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	184 pthread_mutex_unlock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	185 break;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	186 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	187
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	188 Seobeo_Work_Item item = p_pool->p_queue[p_pool->queue_head];
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	189 p_pool->queue_head =
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	190 (p_pool->queue_head + 1) % p_pool->queue_capacity;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	191 p_pool->queue_count--;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	192 p_pool->active_count++;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	193 pthread_mutex_unlock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	194
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	195 Seobeo_Worker_Pool *p_previous_pool = g_current_worker_pool;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	196 g_current_worker_pool = p_pool;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	197 Seobeo_Work_Item_Run(&item);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	198 g_current_worker_pool = p_previous_pool;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	199
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	200 pthread_mutex_lock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	201 p_pool->active_count--;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	202 if (p_pool->queue_count == 0 &&
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	203 p_pool->active_count == 0 &&
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	204 p_pool->cleanup_count == 0)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	205 pthread_cond_broadcast(&p_pool->idle);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	206 pthread_mutex_unlock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	207 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	208 return NULL;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	209 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	210
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	211 Seobeo_Worker_Pool *Seobeo_Worker_Pool_Create(
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	212 uint32 worker_count,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	213 uint32 queue_capacity)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	214 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	215 if (worker_count == 0 \|\| queue_capacity == 0)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	216 return NULL;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	217
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	218 Seobeo_Worker_Pool p_pool = calloc(1, sizeof(p_pool));
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	219 if (!p_pool)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	220 return NULL;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	221 p_pool->p_threads = calloc(worker_count, sizeof(*p_pool->p_threads));
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	222 p_pool->p_queue = calloc(queue_capacity, sizeof(*p_pool->p_queue));
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	223 if (!p_pool->p_threads \|\| !p_pool->p_queue)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	224 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	225 free(p_pool->p_threads);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	226 free(p_pool->p_queue);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	227 free(p_pool);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	228 return NULL;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	229 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	230
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	231 p_pool->worker_count = worker_count;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	232 p_pool->queue_capacity = queue_capacity;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	233 p_pool->accepting = TRUE;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	234 boolean mutex_initialized = FALSE;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	235 boolean work_condition_initialized = FALSE;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	236 boolean idle_condition_initialized = FALSE;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	237 if (pthread_mutex_init(&p_pool->mutex, NULL) == 0)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	238 mutex_initialized = TRUE;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	239 if (mutex_initialized &&
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	240 pthread_cond_init(&p_pool->work_available, NULL) == 0)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	241 work_condition_initialized = TRUE;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	242 if (work_condition_initialized &&
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	243 pthread_cond_init(&p_pool->idle, NULL) == 0)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	244 idle_condition_initialized = TRUE;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	245 if (!idle_condition_initialized)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	246 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	247 if (work_condition_initialized)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	248 pthread_cond_destroy(&p_pool->work_available);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	249 if (mutex_initialized)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	250 pthread_mutex_destroy(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	251 free(p_pool->p_threads);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	252 free(p_pool->p_queue);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	253 free(p_pool);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	254 return NULL;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	255 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	256
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	257 uint32 created = 0;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	258 for (; created < worker_count; created++)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	259 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	260 if (pthread_create(
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	261 &p_pool->p_threads[created],
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	262 NULL,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	263 Seobeo_Worker_Pool_Run,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	264 p_pool) != 0)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	265 break;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	266 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	267 if (created != worker_count)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	268 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	269 pthread_mutex_lock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	270 p_pool->stopping = TRUE;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	271 pthread_cond_broadcast(&p_pool->work_available);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	272 pthread_mutex_unlock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	273 for (uint32 i = 0; i < created; i++)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	274 pthread_join(p_pool->p_threads[i], NULL);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	275 pthread_cond_destroy(&p_pool->idle);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	276 pthread_cond_destroy(&p_pool->work_available);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	277 pthread_mutex_destroy(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	278 free(p_pool->p_threads);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	279 free(p_pool->p_queue);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	280 free(p_pool);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	281 return NULL;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	282 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	283 return p_pool;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	284 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	285
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	286 Seobeo_Worker_Result Seobeo_Worker_Pool_Submit(
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	287 Seobeo_Worker_Pool *p_pool,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	288 Seobeo_Work_Function function,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	289 void *p_context,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	290 Seobeo_Work_Cleanup cleanup)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	291 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	292 if (!p_pool \|\| !function)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	293 return SEOBEO_WORKER_INVALID_ARGUMENT;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	294
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	295 pthread_mutex_lock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	296 if (!p_pool->accepting)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	297 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	298 pthread_mutex_unlock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	299 return SEOBEO_WORKER_STOPPED;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	300 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	301 if (p_pool->queue_count == p_pool->queue_capacity)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	302 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	303 pthread_mutex_unlock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	304 return SEOBEO_WORKER_QUEUE_FULL;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	305 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	306
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	307 uint32 tail =
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	308 (p_pool->queue_head + p_pool->queue_count) %
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	309 p_pool->queue_capacity;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	310 p_pool->p_queue[tail] = (Seobeo_Work_Item){
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	311 .function = function,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	312 .p_context = p_context,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	313 .cleanup = cleanup,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	314 };
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	315 p_pool->queue_count++;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	316 pthread_cond_signal(&p_pool->work_available);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	317 pthread_mutex_unlock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	318 return SEOBEO_WORKER_OK;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	319 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	320
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	321 Seobeo_Worker_Result Seobeo_Worker_Pool_Wait(
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	322 Seobeo_Worker_Pool *p_pool)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	323 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	324 if (!p_pool \|\|
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	325 Seobeo_Worker_Pool_Is_Current_Thread(p_pool) \|\|
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	326 g_current_worker_pool == p_pool)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	327 return SEOBEO_WORKER_INVALID_ARGUMENT;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	328
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	329 pthread_mutex_lock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	330 while (p_pool->queue_count > 0 \|\|
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	331 p_pool->active_count > 0 \|\|
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	332 p_pool->cleanup_count > 0)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	333 pthread_cond_wait(&p_pool->idle, &p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	334 pthread_mutex_unlock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	335 return SEOBEO_WORKER_OK;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	336 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	337
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	338 Seobeo_Worker_Result Seobeo_Worker_Pool_Shutdown(
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	339 Seobeo_Worker_Pool *p_pool,
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	340 boolean drain)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	341 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	342 if (!p_pool \|\|
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	343 Seobeo_Worker_Pool_Is_Current_Thread(p_pool) \|\|
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	344 g_current_worker_pool == p_pool)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	345 return SEOBEO_WORKER_INVALID_ARGUMENT;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	346
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	347 pthread_mutex_lock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	348 if (p_pool->joined)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	349 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	350 pthread_mutex_unlock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	351 return SEOBEO_WORKER_OK;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	352 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	353 if (p_pool->shutdown_started)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	354 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	355 while (!p_pool->joined)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	356 pthread_cond_wait(&p_pool->idle, &p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	357 pthread_mutex_unlock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	358 return SEOBEO_WORKER_OK;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	359 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	360 p_pool->shutdown_started = TRUE;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	361 p_pool->accepting = FALSE;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	362 p_pool->stopping = TRUE;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	363 p_pool->drain = drain;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	364
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	365 if (!drain)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	366 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	367 while (p_pool->queue_count > 0)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	368 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	369 Seobeo_Work_Item item = p_pool->p_queue[p_pool->queue_head];
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	370 p_pool->queue_head =
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	371 (p_pool->queue_head + 1) % p_pool->queue_capacity;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	372 p_pool->queue_count--;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	373 p_pool->cleanup_count++;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	374 pthread_mutex_unlock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	375 if (item.cleanup)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	376 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	377 Seobeo_Worker_Pool *p_previous_pool = g_current_worker_pool;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	378 g_current_worker_pool = p_pool;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	379 item.cleanup(item.p_context);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	380 g_current_worker_pool = p_previous_pool;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	381 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	382 pthread_mutex_lock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	383 p_pool->cleanup_count--;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	384 if (p_pool->queue_count == 0 &&
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	385 p_pool->active_count == 0 &&
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	386 p_pool->cleanup_count == 0)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	387 pthread_cond_broadcast(&p_pool->idle);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	388 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	389 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	390 pthread_cond_broadcast(&p_pool->work_available);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	391 pthread_mutex_unlock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	392
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	393 for (uint32 i = 0; i < p_pool->worker_count; i++)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	394 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	395 if (pthread_join(p_pool->p_threads[i], NULL) != 0)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	396 return SEOBEO_WORKER_THREAD_ERROR;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	397 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	398
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	399 pthread_mutex_lock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	400 p_pool->joined = TRUE;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	401 if (p_pool->active_count == 0 &&
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	402 p_pool->cleanup_count == 0)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	403 pthread_cond_broadcast(&p_pool->idle);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	404 pthread_mutex_unlock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	405 return SEOBEO_WORKER_OK;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	406 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	407
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	408 void Seobeo_Worker_Pool_Destroy(Seobeo_Worker_Pool *p_pool)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	409 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	410 if (!p_pool)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	411 return;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	412 if (Seobeo_Worker_Pool_Is_Current_Thread(p_pool) \|\|
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	413 g_current_worker_pool == p_pool)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	414 return;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	415 if (!p_pool->joined)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	416 (void)Seobeo_Worker_Pool_Shutdown(p_pool, TRUE);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	417 pthread_cond_destroy(&p_pool->idle);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	418 pthread_cond_destroy(&p_pool->work_available);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	419 pthread_mutex_destroy(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	420 free(p_pool->p_threads);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	421 free(p_pool->p_queue);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	422 free(p_pool);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	423 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	424
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	425 uint32 Seobeo_Worker_Pool_Pending(Seobeo_Worker_Pool *p_pool)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	426 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	427 if (!p_pool)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	428 return 0;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	429 pthread_mutex_lock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	430 uint32 count = p_pool->queue_count;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	431 pthread_mutex_unlock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	432 return count;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	433 }
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	434
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	435 uint32 Seobeo_Worker_Pool_Active(Seobeo_Worker_Pool *p_pool)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	436 {
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	437 if (!p_pool)
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	438 return 0;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	439 pthread_mutex_lock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	440 uint32 count = p_pool->active_count;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	441 pthread_mutex_unlock(&p_pool->mutex);
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	442 return count;
745fd127b2a1 [seobeo] Add bounded worker interface MrJuneJune <me@mrjunejune.com> parents: diff changeset	443 }

Mercurial

annotate seobeo/s_worker.c @ 273:e02e2036ef84 default tip