ui/common/threadpool.c

Sun, 09 Jun 2024 15:42:26 +0200

author
Olaf Wintermann <olaf.wintermann@gmail.com>
date
Sun, 09 Jun 2024 15:42:26 +0200
branch
newapi
changeset 284
f93c368518c0
parent 280
e3565cf7c831
child 288
c5e89affb2ea
permissions
-rw-r--r--

fix menu lists (GTK3)

280
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
1 /*
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
2 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
3 *
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
4 * Copyright 2024 Olaf Wintermann. All rights reserved.
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
5 *
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
6 * Redistribution and use in source and binary forms, with or without
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
7 * modification, are permitted provided that the following conditions are met:
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
8 *
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
9 * 1. Redistributions of source code must retain the above copyright
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
10 * notice, this list of conditions and the following disclaimer.
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
11 *
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
12 * 2. Redistributions in binary form must reproduce the above copyright
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
13 * notice, this list of conditions and the following disclaimer in the
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
14 * documentation and/or other materials provided with the distribution.
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
15 *
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
16 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
17 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
18 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
19 * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
20 * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
21 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
22 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
23 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
24 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
25 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
26 * POSSIBILITY OF SUCH DAMAGE.
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
27 */
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
28
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
29 #include "threadpool.h"
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
30
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
31 #include <pthread.h>
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
32
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
33 #ifndef _WIN32
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
34
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
35
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
36 static threadpool_job kill_job;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
37
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
38 UiThreadpool* threadpool_new(int min, int max) {
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
39 UiThreadpool *pool = malloc(sizeof(UiThreadpool));
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
40 pool->queue = NULL;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
41 pool->queue_len = 0;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
42 pool->num_idle = 0;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
43 pool->min_threads = min;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
44 pool->max_threads = max;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
45
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
46 pthread_mutex_init(&pool->queue_lock, NULL);
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
47 pthread_mutex_init(&pool->avlbl_lock, NULL);
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
48 pthread_cond_init(&pool->available, NULL);
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
49
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
50 return pool;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
51 }
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
52
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
53 int threadpool_start(UiThreadpool *pool) {
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
54 /* create pool threads */
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
55 for(int i=0;i<pool->min_threads;i++) {
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
56 pthread_t t;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
57 if (pthread_create(&t, NULL, threadpool_func, pool) != 0) {
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
58 fprintf(stderr, "uic: threadpool_start: pthread_create failed: %s", strerror(errno));
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
59 return 1;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
60 }
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
61 }
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
62 return 0;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
63 }
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
64
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
65 void* threadpool_func(void *data) {
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
66 UiThreadpool *pool = (UiThreadpool*)data;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
67
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
68 for(;;) {
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
69 threadpool_job *job = threadpool_get_job(pool);
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
70 if(job == &kill_job) {
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
71 break;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
72 }
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
73
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
74 job->callback(job->data);
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
75
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
76 free(job);
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
77 }
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
78 return NULL;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
79 }
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
80
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
81 threadpool_job* threadpool_get_job(UiThreadpool *pool) {
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
82 pthread_mutex_lock(&pool->queue_lock);
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
83
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
84 threadpool_job *job = NULL;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
85 pool->num_idle++;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
86 while(job == NULL) {
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
87 if(pool->queue_len == 0) {
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
88 pthread_cond_wait(&pool->available, &pool->queue_lock);
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
89 continue;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
90 } else {
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
91 pool_queue_t *q = pool->queue;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
92 job = q->job;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
93 pool->queue = q->next;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
94 pool->queue_len--;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
95 free(q);
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
96 }
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
97 }
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
98 pool->num_idle--;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
99
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
100 pthread_mutex_unlock(&pool->queue_lock);
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
101 return job;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
102 }
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
103
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
104 void threadpool_run(UiThreadpool *pool, job_callback_f func, void *data) {
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
105 // TODO: handle errors
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
106
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
107 threadpool_job *job = malloc(sizeof(threadpool_job));
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
108 job->callback = func;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
109 job->data = data;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
110
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
111 pthread_mutex_lock(&pool->queue_lock);
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
112 threadpool_enqueue_job(pool, job);
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
113
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
114 int create_thread = 0;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
115 int destroy_thread = 0;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
116 int diff = pool->queue_len - pool->num_idle;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
117
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
118 //if(pool->queue_len == 1) {
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
119 pthread_cond_signal(&pool->available);
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
120 //}
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
121
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
122 pthread_mutex_unlock(&pool->queue_lock);
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
123 }
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
124
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
125 void threadpool_enqueue_job(UiThreadpool *pool, threadpool_job *job) {
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
126 pool_queue_t *q = malloc(sizeof(pool_queue_t));
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
127 q->job = job;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
128 q->next = NULL;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
129
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
130 if(pool->queue == NULL) {
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
131 pool->queue = q;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
132 } else {
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
133 pool_queue_t *last_elem = pool->queue;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
134 while(last_elem->next != NULL) {
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
135 last_elem = last_elem->next;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
136 }
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
137 last_elem->next = q;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
138 }
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
139 pool->queue_len++;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
140 }
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
141
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
142
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
143
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
144
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
145
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
146
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
147 UiThreadpool* ui_threadpool_create(int nthreads) {
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
148 return threadpool_new(nthreads, nthreads);
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
149 }
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
150
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
151 void ui_threadpool_destroy(UiThreadpool* pool) {
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
152
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
153 }
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
154
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
155 static void* ui_threadpool_job_func(void *data) {
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
156 UiJob *job = data;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
157
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
158 free(job);
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
159 return NULL;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
160 }
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
161
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
162 void ui_threadpool_job(UiThreadpool* pool, UiObject* obj, ui_threadfunc tf, void* td, ui_callback f, void* fd) {
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
163 UiJob* job = malloc(sizeof(UiJob));
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
164 job->obj = obj;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
165 job->job_func = tf;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
166 job->job_data = td;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
167 job->finish_callback = f;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
168 job->finish_data = fd;
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
169 threadpool_run(pool, ui_threadpool_job_func, job);
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
170 }
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
171
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
172
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
173 #endif
e3565cf7c831 add threadpool
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff changeset
174

mercurial