Retro/pcem
Watch
1
0
Fork
You've already forked pcem
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Improved pthread code.

Browse source
This commit is contained in:
SarahW 2017-12-11 16:32:48 +00:00
commit baf6b83cfd
1 changed files with 13 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

15
src/wx-thread.c
View file

@ -77,6 +77,7 @@ typedef struct event_pthread_t
{ {
pthread_cond_t cond; pthread_cond_t cond;
pthread_mutex_t mutex; pthread_mutex_t mutex;
int state;
} event_pthread_t; } event_pthread_t;
thread_t *thread_create(void (*thread_rout)(void *param), void *param) thread_t *thread_create(void (*thread_rout)(void *param), void *param)
@ -104,6 +105,7 @@ event_t *thread_create_event()
pthread_cond_init(&event->cond, NULL); pthread_cond_init(&event->cond, NULL);
pthread_mutex_init(&event->mutex, NULL); pthread_mutex_init(&event->mutex, NULL);
event->state = 0;
return (event_t *)event; return (event_t *)event;
} }
@ -113,12 +115,18 @@ void thread_set_event(event_t *handle)
event_pthread_t *event = (event_pthread_t *)handle; event_pthread_t *event = (event_pthread_t *)handle;
pthread_mutex_lock(&event->mutex); pthread_mutex_lock(&event->mutex);
event->state = 1;
pthread_cond_broadcast(&event->cond); pthread_cond_broadcast(&event->cond);
pthread_mutex_unlock(&event->mutex); pthread_mutex_unlock(&event->mutex);
} }
void thread_reset_event(event_t *handle) void thread_reset_event(event_t *handle)
{ {
event_pthread_t *event = (event_pthread_t *)handle;
pthread_mutex_lock(&event->mutex);
event->state = 0;
pthread_mutex_unlock(&event->mutex);
} }
int thread_wait_event(event_t *handle, int timeout) int thread_wait_event(event_t *handle, int timeout)
@ -144,8 +152,11 @@ int thread_wait_event(event_t *handle, int timeout)
pthread_mutex_lock(&event->mutex); pthread_mutex_lock(&event->mutex);
if (timeout == -1) if (timeout == -1)
pthread_cond_wait(&event->cond, &event->mutex); {
else while (!event->state)
pthread_cond_wait(&event->cond, &event->mutex);
}
else if (!event->state)
pthread_cond_timedwait(&event->cond, &event->mutex, &abstime); pthread_cond_timedwait(&event->cond, &event->mutex, &abstime);
pthread_mutex_unlock(&event->mutex); pthread_mutex_unlock(&event->mutex);