author | truebrain |
Fri, 13 Jun 2008 19:57:25 +0000 | |
branch | noai |
changeset 10957 | 7a140b4cd91d |
parent 10867 | 5de2923d6e59 |
child 11095 | a0da321a39b3 |
permissions | -rw-r--r-- |
9857
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
1 |
/* $Id$ */ |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
2 |
|
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
3 |
/** @file thread_pthread.cpp POSIX pthread implementation of Threads. */ |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
4 |
|
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
5 |
#include "stdafx.h" |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
6 |
#include "thread.h" |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
7 |
#include "debug.h" |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
8 |
#include "core/alloc_func.hpp" |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
9 |
#include <stdlib.h> |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
10 |
#include <pthread.h> |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
11 |
#include <semaphore.h> |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
12 |
#include <unistd.h> |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
13 |
|
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
14 |
/** |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
15 |
* POSIX pthread version for ThreadObject. |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
16 |
*/ |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
17 |
class ThreadObject_pthread : public ThreadObject { |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
18 |
private: |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
19 |
pthread_t m_thr; ///< System thread identifier. |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
20 |
OTTDThreadFunc m_proc; ///< External thread procedure. |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
21 |
void *m_param; ///< Parameter for the external thread procedure. |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
22 |
bool m_attached; ///< True if the ThreadObject was attached to an existing thread. |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
23 |
sem_t m_sem_start; ///< Here the new thread waits before it starts. |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
24 |
sem_t m_sem_stop; ///< Here the other thread can wait for this thread to end. |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
25 |
|
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
26 |
public: |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
27 |
/** |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
28 |
* Create a pthread and start it, calling proc(param). |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
29 |
*/ |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
30 |
ThreadObject_pthread(OTTDThreadFunc proc, void *param) : |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
31 |
m_thr(0), |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
32 |
m_proc(proc), |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
33 |
m_param(param), |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
34 |
m_attached(false) |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
35 |
{ |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
36 |
sem_init(&m_sem_start, 0, 0); |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
37 |
sem_init(&m_sem_stop, 0, 0); |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
38 |
|
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
39 |
pthread_create(&m_thr, NULL, &stThreadProc, this); |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
40 |
sem_post(&m_sem_start); |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
41 |
} |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
42 |
|
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
43 |
/** |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
44 |
* Create a pthread and attach current thread to it. |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
45 |
*/ |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
46 |
ThreadObject_pthread() : |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
47 |
m_thr(0), |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
48 |
m_proc(NULL), |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
49 |
m_param(0), |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
50 |
m_attached(true) |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
51 |
{ |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
52 |
sem_init(&m_sem_start, 0, 0); |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
53 |
sem_init(&m_sem_stop, 0, 0); |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
54 |
|
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
55 |
m_thr = pthread_self(); |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
56 |
} |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
57 |
|
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
58 |
/* virtual */ ~ThreadObject_pthread() |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
59 |
{ |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
60 |
sem_destroy(&m_sem_stop); |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
61 |
sem_destroy(&m_sem_start); |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
62 |
}; |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
63 |
|
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
64 |
/* virtual */ bool IsRunning() |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
65 |
{ |
10455
22c441f5adf9
(svn r12997) [NoAI] -Sync: with trunk r12895:12996.
rubidium
parents:
10172
diff
changeset
|
66 |
int sval; |
22c441f5adf9
(svn r12997) [NoAI] -Sync: with trunk r12895:12996.
rubidium
parents:
10172
diff
changeset
|
67 |
sem_getvalue(&m_sem_stop, &sval); |
22c441f5adf9
(svn r12997) [NoAI] -Sync: with trunk r12895:12996.
rubidium
parents:
10172
diff
changeset
|
68 |
return sval == 0; |
9857
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
69 |
} |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
70 |
|
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
71 |
/* virtual */ bool WaitForStop() |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
72 |
{ |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
73 |
/* You can't wait on yourself */ |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
74 |
assert(!IsCurrent()); |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
75 |
/* If the thread is not running, waiting is over */ |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
76 |
if (!IsRunning()) return true; |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
77 |
|
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
78 |
int ret = sem_wait(&m_sem_stop); |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
79 |
if (ret == 0) { |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
80 |
/* We have passed semaphore so increment it again */ |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
81 |
sem_post(&m_sem_stop); |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
82 |
return true; |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
83 |
} |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
84 |
return false; |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
85 |
} |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
86 |
|
9859
81621c6ba0e9
(svn r12538) [NoAI] -Codechange: introducing fiber.hpp, a class to have fibers in your application via either Windows Fibers, or via thread.h
truebrain
parents:
9857
diff
changeset
|
87 |
/* virtual */ bool Exit() |
81621c6ba0e9
(svn r12538) [NoAI] -Codechange: introducing fiber.hpp, a class to have fibers in your application via either Windows Fibers, or via thread.h
truebrain
parents:
9857
diff
changeset
|
88 |
{ |
81621c6ba0e9
(svn r12538) [NoAI] -Codechange: introducing fiber.hpp, a class to have fibers in your application via either Windows Fibers, or via thread.h
truebrain
parents:
9857
diff
changeset
|
89 |
/* You can only exit yourself */ |
81621c6ba0e9
(svn r12538) [NoAI] -Codechange: introducing fiber.hpp, a class to have fibers in your application via either Windows Fibers, or via thread.h
truebrain
parents:
9857
diff
changeset
|
90 |
assert(IsCurrent()); |
81621c6ba0e9
(svn r12538) [NoAI] -Codechange: introducing fiber.hpp, a class to have fibers in your application via either Windows Fibers, or via thread.h
truebrain
parents:
9857
diff
changeset
|
91 |
/* If the thread is not running, we are already closed */ |
81621c6ba0e9
(svn r12538) [NoAI] -Codechange: introducing fiber.hpp, a class to have fibers in your application via either Windows Fibers, or via thread.h
truebrain
parents:
9857
diff
changeset
|
92 |
if (!IsRunning()) return false; |
81621c6ba0e9
(svn r12538) [NoAI] -Codechange: introducing fiber.hpp, a class to have fibers in your application via either Windows Fibers, or via thread.h
truebrain
parents:
9857
diff
changeset
|
93 |
|
81621c6ba0e9
(svn r12538) [NoAI] -Codechange: introducing fiber.hpp, a class to have fibers in your application via either Windows Fibers, or via thread.h
truebrain
parents:
9857
diff
changeset
|
94 |
/* For now we terminate by throwing an error, gives much cleaner cleanup */ |
81621c6ba0e9
(svn r12538) [NoAI] -Codechange: introducing fiber.hpp, a class to have fibers in your application via either Windows Fibers, or via thread.h
truebrain
parents:
9857
diff
changeset
|
95 |
throw 0; |
81621c6ba0e9
(svn r12538) [NoAI] -Codechange: introducing fiber.hpp, a class to have fibers in your application via either Windows Fibers, or via thread.h
truebrain
parents:
9857
diff
changeset
|
96 |
} |
81621c6ba0e9
(svn r12538) [NoAI] -Codechange: introducing fiber.hpp, a class to have fibers in your application via either Windows Fibers, or via thread.h
truebrain
parents:
9857
diff
changeset
|
97 |
|
10867
5de2923d6e59
(svn r13418) [NoAI] -Sync: with trunk r13380:13417.
rubidium
parents:
10613
diff
changeset
|
98 |
/* virtual */ void Join() |
9859
81621c6ba0e9
(svn r12538) [NoAI] -Codechange: introducing fiber.hpp, a class to have fibers in your application via either Windows Fibers, or via thread.h
truebrain
parents:
9857
diff
changeset
|
99 |
{ |
81621c6ba0e9
(svn r12538) [NoAI] -Codechange: introducing fiber.hpp, a class to have fibers in your application via either Windows Fibers, or via thread.h
truebrain
parents:
9857
diff
changeset
|
100 |
/* You cannot join yourself */ |
81621c6ba0e9
(svn r12538) [NoAI] -Codechange: introducing fiber.hpp, a class to have fibers in your application via either Windows Fibers, or via thread.h
truebrain
parents:
9857
diff
changeset
|
101 |
assert(!IsCurrent()); |
81621c6ba0e9
(svn r12538) [NoAI] -Codechange: introducing fiber.hpp, a class to have fibers in your application via either Windows Fibers, or via thread.h
truebrain
parents:
9857
diff
changeset
|
102 |
|
10867
5de2923d6e59
(svn r13418) [NoAI] -Sync: with trunk r13380:13417.
rubidium
parents:
10613
diff
changeset
|
103 |
pthread_join(m_thr, NULL); |
9859
81621c6ba0e9
(svn r12538) [NoAI] -Codechange: introducing fiber.hpp, a class to have fibers in your application via either Windows Fibers, or via thread.h
truebrain
parents:
9857
diff
changeset
|
104 |
m_thr = 0; |
81621c6ba0e9
(svn r12538) [NoAI] -Codechange: introducing fiber.hpp, a class to have fibers in your application via either Windows Fibers, or via thread.h
truebrain
parents:
9857
diff
changeset
|
105 |
} |
81621c6ba0e9
(svn r12538) [NoAI] -Codechange: introducing fiber.hpp, a class to have fibers in your application via either Windows Fibers, or via thread.h
truebrain
parents:
9857
diff
changeset
|
106 |
|
9857
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
107 |
/* virtual */ bool IsCurrent() |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
108 |
{ |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
109 |
return pthread_self() == m_thr; |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
110 |
} |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
111 |
|
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
112 |
/* virtual */ uint GetId() |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
113 |
{ |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
114 |
return (uint)m_thr; |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
115 |
} |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
116 |
|
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
117 |
private: |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
118 |
/** |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
119 |
* On thread creation, this function is called, which calls the real startup |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
120 |
* function. This to get back into the correct instance again. |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
121 |
*/ |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
122 |
static void *stThreadProc(void *thr) |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
123 |
{ |
10867
5de2923d6e59
(svn r13418) [NoAI] -Sync: with trunk r13380:13417.
rubidium
parents:
10613
diff
changeset
|
124 |
((ThreadObject_pthread *)thr)->ThreadProc(); |
5de2923d6e59
(svn r13418) [NoAI] -Sync: with trunk r13380:13417.
rubidium
parents:
10613
diff
changeset
|
125 |
pthread_exit(NULL); |
9857
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
126 |
} |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
127 |
|
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
128 |
/** |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
129 |
* A new thread is created, and this function is called. Call the custom |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
130 |
* function of the creator of the thread. |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
131 |
*/ |
10867
5de2923d6e59
(svn r13418) [NoAI] -Sync: with trunk r13380:13417.
rubidium
parents:
10613
diff
changeset
|
132 |
void ThreadProc() |
9857
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
133 |
{ |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
134 |
/* The new thread stops here so the calling thread can complete pthread_create() call */ |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
135 |
sem_wait(&m_sem_start); |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
136 |
|
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
137 |
/* Call the proc of the creator to continue this thread */ |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
138 |
try { |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
139 |
m_proc(m_param); |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
140 |
} catch (...) { |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
141 |
} |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
142 |
|
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
143 |
/* Notify threads waiting for our completion */ |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
144 |
sem_post(&m_sem_stop); |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
145 |
} |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
146 |
}; |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
147 |
|
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
148 |
/* static */ ThreadObject *ThreadObject::New(OTTDThreadFunc proc, void *param) |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
149 |
{ |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
150 |
return new ThreadObject_pthread(proc, param); |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
151 |
} |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
152 |
|
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
153 |
/* static */ ThreadObject *ThreadObject::AttachCurrent() |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
154 |
{ |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
155 |
return new ThreadObject_pthread(); |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
156 |
} |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
157 |
|
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
158 |
/* static */ uint ThreadObject::CurrentId() |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
159 |
{ |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
160 |
return (uint)pthread_self(); |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
161 |
} |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
162 |
|
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
163 |
|
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
164 |
/** |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
165 |
* POSIX pthread version of ThreadSemaphore. |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
166 |
*/ |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
167 |
class ThreadSemaphore_pthread : public ThreadSemaphore { |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
168 |
private: |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
169 |
sem_t m_sem; |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
170 |
|
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
171 |
public: |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
172 |
ThreadSemaphore_pthread() |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
173 |
{ |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
174 |
sem_init(&m_sem, 0, 0); |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
175 |
} |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
176 |
|
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
177 |
/* virtual */ ~ThreadSemaphore_pthread() |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
178 |
{ |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
179 |
sem_destroy(&m_sem); |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
180 |
} |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
181 |
|
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
182 |
/* virtual */ void Set() |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
183 |
{ |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
184 |
int val = 0; |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
185 |
if (sem_getvalue(&m_sem, &val) == 0 && val == 0) sem_post(&m_sem); |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
186 |
} |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
187 |
|
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
188 |
/* virtual */ void Wait() |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
189 |
{ |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
190 |
sem_wait(&m_sem); |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
191 |
} |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
192 |
}; |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
193 |
|
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
194 |
/* static */ ThreadSemaphore *ThreadSemaphore::New() |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
195 |
{ |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
196 |
return new ThreadSemaphore_pthread(); |
7adb6a846add
(svn r12529) [NoAI] -Change: split thread.cpp into 4 files, one for each OS
truebrain
parents:
diff
changeset
|
197 |
} |