PCem

view src/thread-pthread.c @ 154:d0d530adce12

find changesets by author, revision, files, or words in the commit message
Initial port to Linux (using Allegro). 64-bit fixes. Some changes to aid portability. A few other tweaks.
author TomW
date Thu Sep 04 21:07:24 2014 +0100
parents
children
line source
1 #include <stdlib.h>
2 #include <stdio.h>
3 #include <time.h>
4 #include <pthread.h>
5 #include "thread.h"
6
7 typedef struct event_pthread_t
8 {
9 pthread_cond_t cond;
10 pthread_mutex_t mutex;
11 } event_pthread_t;
12
13 thread_t *thread_create(void (*thread_rout)(void *param), void *param)
14 {
15 pthread_t *thread = malloc(sizeof(pthread_t));
16
17 pthread_create(thread, NULL, thread_rout, param);
18
19 return thread;
20 }
21
22 void thread_kill(thread_t *handle)
23 {
24 pthread_t *thread = (pthread_t *)handle;
25
26 pthread_cancel(*thread);
27 pthread_join(*thread, NULL);
28
29 free(thread);
30 }
31
32 event_t *thread_create_event()
33 {
34 event_pthread_t *event = malloc(sizeof(event_pthread_t));
35
36 pthread_cond_init(&event->cond, NULL);
37 pthread_mutex_init(&event->mutex, NULL);
38
39 return (event_t *)event;
40 }
41
42 void thread_set_event(event_t *handle)
43 {
44 event_pthread_t *event = (event_pthread_t *)handle;
45
46 pthread_mutex_lock(&event->mutex);
47 pthread_cond_broadcast(&event->cond);
48 pthread_mutex_unlock(&event->mutex);
49 }
50
51 void thread_reset_event(event_t *handle)
52 {
53 }
54
55 int thread_wait_event(event_t *handle, int timeout)
56 {
57 event_pthread_t *event = (event_pthread_t *)handle;
58 struct timespec abstime;
59
60 clock_gettime(CLOCK_REALTIME, &abstime);
61 abstime.tv_nsec += (timeout % 1000) * 1000000;
62 abstime.tv_sec += (timeout / 1000);
63 if (abstime.tv_nsec > 1000000000)
64 {
65 abstime.tv_nsec -= 1000000000;
66 abstime.tv_sec++;
67 }
68
69 pthread_mutex_lock(&event->mutex);
70 pthread_cond_timedwait(&event->cond, &event->mutex, &abstime);
71 pthread_mutex_unlock(&event->mutex);
72
73 return 0;
74 }
75
76 void thread_destroy_event(event_t *handle)
77 {
78 event_pthread_t *event = (event_pthread_t *)handle;
79
80 pthread_cond_destroy(&event->cond);
81 pthread_mutex_destroy(&event->mutex);
82
83 free(event);
84 }
85
86 void thread_sleep(int t)
87 {
88 usleep(t * 1000);
89 }