Add yaz_thread_{create,join,detach}
[yaz-moved-to-github.git] / src / thread_create.c
1 /* This file is part of the YAZ toolkit.
2  * Copyright (C) 1995-2010 Index Data
3  * See the file LICENSE for details.
4  */
5
6 /**
7  * \file thread_create.c
8  * \brief Implements thread creation wrappers
9  *
10  */
11 #if HAVE_CONFIG_H
12 #include <config.h>
13 #endif
14
15 #include <assert.h>
16 #include <stdlib.h>
17 #include <string.h>
18 #include <errno.h>
19 #include <stddef.h>
20 #include <yaz/xmalloc.h>
21 #include <yaz/log.h>
22 #include <yaz/thread_create.h>
23
24 #if YAZ_POSIX_THREADS
25 #include <pthread.h>
26 #endif
27 #ifdef WIN32
28 #include <windows.h>
29 #endif
30
31 struct yaz_thread {
32 #if YAZ_POSIX_THREADS
33     pthread_t id;
34 #else
35     void *return_data;
36 #ifdef WIN32
37     HANDLE id;
38 #endif
39 #endif
40 };
41
42 yaz_thread_t yaz_thread_create(void *(*start_routine)(void *p), void *arg)
43 {
44     yaz_thread_t t = xmalloc(sizeof(*t));
45 #if YAZ_POSIX_THREADS
46     int r = pthread_create(&t->id, 0, start_routine, arg);
47     if (r)
48     {
49         xfree(t);
50         t = 0;
51     }
52 #else
53     t->return_data = start_routine(arg);
54 #endif
55     return t;
56 }
57
58 void yaz_thread_join(yaz_thread_t *tp, void **value_ptr)
59 {
60     if (*tp)
61     {
62 #ifdef YAZ_POSIX_THREADS
63         pthread_join((*tp)->id, value_ptr);
64 #else
65         if (value_ptr)
66             *value_ptr = (*tp)->return_data;
67 #endif
68         xfree(*tp);
69         *tp = 0;
70     }
71 }
72
73 void yaz_thread_detach(yaz_thread_t *tp)
74 {
75     if (*tp)
76     {
77 #ifdef YAZ_POSIX_THREADS
78         pthread_detach((*tp)->id);
79 #endif
80         xfree(*tp);
81         *tp = 0;
82     }
83 }
84
85 /*
86  * Local variables:
87  * c-basic-offset: 4
88  * c-file-style: "Stroustrup"
89  * indent-tabs-mode: nil
90  * End:
91  * vim: shiftwidth=4 tabstop=8 expandtab
92  */
93