1 // win32-threads.cc - interface between libjava and Win32 threads.
3 /* Copyright (C) 1998, 1999, 2000, 2001, 2002, 2003 Free Software
6 This file is part of libgcj.
8 This software is copyrighted work licensed under the terms of the
9 Libgcj License. Please consult the file "LIBGCJ_LICENSE" for
14 // If we're using the Boehm GC, then we need to override some of the
15 // thread primitives. This is fairly gross.
20 // <windows.h> #define's STRICT, which conflicts with Modifier.h
23 #endif /* HAVE_BOEHM_GC */
27 #include <java/lang/Thread.h>
28 #include <java/lang/System.h>
36 // This is used to implement thread startup.
39 _Jv_ThreadStartFunc
*method
;
43 // Controls access to the variable below
44 static HANDLE daemon_mutex
;
45 static HANDLE daemon_cond
;
46 // Number of non-daemon threads - _Jv_ThreadWait returns when this is 0
47 static int non_daemon_count
;
49 // TLS key get Java object representing the thread
51 // TLS key to get _Jv_Thread_t* representing the thread
52 DWORD _Jv_ThreadDataKey
;
55 // These are the flags that can appear in _Jv_Thread_t.
59 #define FLAG_START 0x01
61 #define FLAG_DAEMON 0x02
64 // Condition variables.
67 // we do lazy creation of Events since CreateEvent() is insanely
68 // expensive, and because the rest of libgcj will call _Jv_CondInit
69 // when only a mutex is needed.
72 ensure_condvar_initialized(_Jv_ConditionVariable_t
*cv
)
76 cv
->ev
[0] = CreateEvent (NULL
, 0, 0, NULL
);
77 if (cv
->ev
[0] == 0) JvFail("CreateEvent() failed");
79 cv
->ev
[1] = CreateEvent (NULL
, 1, 0, NULL
);
80 if (cv
->ev
[1] == 0) JvFail("CreateEvent() failed");
85 ensure_interrupt_event_initialized(HANDLE
& rhEvent
)
89 rhEvent
= CreateEvent (NULL
, 0, 0, NULL
);
90 if (!rhEvent
) JvFail("CreateEvent() failed");
94 // Reimplementation of the general algorithm described at
95 // http://www.cs.wustl.edu/~schmidt/win32-cv-1.html (isomorphic to
96 // 3.2, not a cut-and-paste).
99 _Jv_CondWait(_Jv_ConditionVariable_t
*cv
, _Jv_Mutex_t
*mu
, jlong millis
, jint nanos
)
101 if (mu
->owner
!= GetCurrentThreadId ( ))
102 return _JV_NOT_OWNER
;
104 _Jv_Thread_t
*current
= _Jv_ThreadCurrentData ();
105 java::lang::Thread
*current_obj
= _Jv_ThreadCurrent ();
107 // Now that we hold the interrupt mutex, check if this thread has been
108 // interrupted already.
109 EnterCriticalSection (¤t
->interrupt_mutex
);
110 ensure_interrupt_event_initialized (current
->interrupt_event
);
111 jboolean interrupted
= current_obj
->interrupt_flag
;
112 LeaveCriticalSection (¤t
->interrupt_mutex
);
116 return _JV_INTERRUPTED
;
119 EnterCriticalSection (&cv
->count_mutex
);
120 ensure_condvar_initialized (cv
);
122 LeaveCriticalSection (&cv
->count_mutex
);
125 if ((millis
== 0) && (nanos
> 0)) time
= 1;
126 else if (millis
== 0) time
= INFINITE
;
129 _Jv_MutexUnlock (mu
);
131 // Set up our array of three events:
132 // - the auto-reset event (for notify())
133 // - the manual-reset event (for notifyAll())
134 // - the interrupt event (for interrupt())
135 // We wait for any one of these to be signaled.
139 arh
[2] = current
->interrupt_event
;
140 DWORD rval
= WaitForMultipleObjects (3, arh
, 0, time
);
142 EnterCriticalSection (¤t
->interrupt_mutex
);
144 // If we were unblocked by the third event (our thread's interrupt
145 // event), set the thread's interrupt flag. I think this sanity
146 // check guards against someone resetting our interrupt flag
147 // in the time between when interrupt_mutex is released in
148 // _Jv_ThreadInterrupt and the interval of time between the
149 // WaitForMultipleObjects call we just made and our acquisition
150 // of interrupt_mutex.
151 if (rval
== (WAIT_OBJECT_0
+ 2))
152 current_obj
->interrupt_flag
= true;
154 interrupted
= current_obj
->interrupt_flag
;
155 LeaveCriticalSection (¤t
->interrupt_mutex
);
157 EnterCriticalSection(&cv
->count_mutex
);
159 // If we were unblocked by the second event (the broadcast one)
160 // and nobody is left, then reset the event.
161 int last_waiter
= (rval
== (WAIT_OBJECT_0
+ 1)) && (cv
->blocked_count
== 0);
162 LeaveCriticalSection(&cv
->count_mutex
);
165 ResetEvent (cv
->ev
[1]);
169 return interrupted
? _JV_INTERRUPTED
: 0;
173 _Jv_CondInit (_Jv_ConditionVariable_t
*cv
)
175 // we do lazy creation of Events since CreateEvent() is insanely expensive
177 InitializeCriticalSection (&cv
->count_mutex
);
178 cv
->blocked_count
= 0;
182 _Jv_CondDestroy (_Jv_ConditionVariable_t
*cv
)
186 CloseHandle (cv
->ev
[0]);
187 CloseHandle (cv
->ev
[1]);
192 DeleteCriticalSection (&cv
->count_mutex
);
196 _Jv_CondNotify (_Jv_ConditionVariable_t
*cv
, _Jv_Mutex_t
*mu
)
198 if (mu
->owner
!= GetCurrentThreadId ( ))
199 return _JV_NOT_OWNER
;
201 EnterCriticalSection (&cv
->count_mutex
);
202 ensure_condvar_initialized (cv
);
203 int somebody_is_blocked
= cv
->blocked_count
> 0;
204 LeaveCriticalSection (&cv
->count_mutex
);
206 if (somebody_is_blocked
)
207 SetEvent (cv
->ev
[0]);
213 _Jv_CondNotifyAll (_Jv_ConditionVariable_t
*cv
, _Jv_Mutex_t
*mu
)
215 if (mu
->owner
!= GetCurrentThreadId ( ))
216 return _JV_NOT_OWNER
;
218 EnterCriticalSection (&cv
->count_mutex
);
219 ensure_condvar_initialized (cv
);
220 int somebody_is_blocked
= cv
->blocked_count
> 0;
221 LeaveCriticalSection (&cv
->count_mutex
);
223 if (somebody_is_blocked
)
224 SetEvent (cv
->ev
[1]);
234 _Jv_InitThreads (void)
236 _Jv_ThreadKey
= TlsAlloc();
237 _Jv_ThreadDataKey
= TlsAlloc();
238 daemon_mutex
= CreateMutex (NULL
, 0, NULL
);
239 daemon_cond
= CreateEvent (NULL
, 1, 0, NULL
);
240 non_daemon_count
= 0;
244 _Jv_ThreadInitData (java::lang::Thread
* obj
)
246 _Jv_Thread_t
*data
= (_Jv_Thread_t
*)_Jv_Malloc(sizeof(_Jv_Thread_t
));
248 data
->thread_obj
= obj
;
249 data
->interrupt_event
= 0;
250 InitializeCriticalSection (&data
->interrupt_mutex
);
256 _Jv_ThreadDestroyData (_Jv_Thread_t
*data
)
258 DeleteCriticalSection (&data
->interrupt_mutex
);
259 if (data
->interrupt_event
)
260 CloseHandle(data
->interrupt_event
);
265 _Jv_ThreadSetPriority (_Jv_Thread_t
*data
, jint prio
)
267 int actual
= THREAD_PRIORITY_NORMAL
;
269 if (data
->flags
& FLAG_START
)
274 actual
= THREAD_PRIORITY_TIME_CRITICAL
;
277 actual
= THREAD_PRIORITY_HIGHEST
;
281 actual
= THREAD_PRIORITY_ABOVE_NORMAL
;
285 actual
= THREAD_PRIORITY_NORMAL
;
289 actual
= THREAD_PRIORITY_BELOW_NORMAL
;
292 actual
= THREAD_PRIORITY_LOWEST
;
295 actual
= THREAD_PRIORITY_IDLE
;
298 SetThreadPriority(data
->handle
, actual
);
303 _Jv_ThreadRegister (_Jv_Thread_t
*data
)
305 TlsSetValue (_Jv_ThreadKey
, data
->thread_obj
);
306 TlsSetValue (_Jv_ThreadDataKey
, data
);
310 _Jv_ThreadUnRegister ()
312 TlsSetValue (_Jv_ThreadKey
, NULL
);
313 TlsSetValue (_Jv_ThreadDataKey
, NULL
);
316 // This function is called when a thread is started. We don't arrange
317 // to call the `run' method directly, because this function must
320 really_start (void* x
)
322 struct starter
*info
= (struct starter
*) x
;
324 _Jv_ThreadRegister (info
->data
);
326 info
->method (info
->data
->thread_obj
);
328 if (! (info
->data
->flags
& FLAG_DAEMON
))
330 WaitForSingleObject (daemon_mutex
, INFINITE
);
332 if (! non_daemon_count
)
333 SetEvent (daemon_cond
);
334 ReleaseMutex (daemon_mutex
);
341 _Jv_ThreadStart (java::lang::Thread
*thread
, _Jv_Thread_t
*data
, _Jv_ThreadStartFunc
*meth
)
344 struct starter
*info
;
346 // Do nothing if thread has already started
347 if (data
->flags
& FLAG_START
)
349 data
->flags
|= FLAG_START
;
351 // FIXME: handle marking the info object for GC.
352 info
= (struct starter
*) _Jv_AllocBytes (sizeof (struct starter
));
356 if (! thread
->isDaemon ())
358 WaitForSingleObject (daemon_mutex
, INFINITE
);
360 ReleaseMutex (daemon_mutex
);
363 data
->flags
|= FLAG_DAEMON
;
365 GC_CreateThread(NULL
, 0, really_start
, info
, 0, &id
);
366 _Jv_ThreadSetPriority(data
, thread
->getPriority());
370 _Jv_ThreadWait (void)
372 WaitForSingleObject (daemon_mutex
, INFINITE
);
373 if (non_daemon_count
)
375 ReleaseMutex (daemon_mutex
);
376 WaitForSingleObject (daemon_cond
, INFINITE
);
385 _Jv_Win32GetInterruptEvent (void)
387 _Jv_Thread_t
*current
= _Jv_ThreadCurrentData ();
388 EnterCriticalSection (¤t
->interrupt_mutex
);
389 ensure_interrupt_event_initialized (current
->interrupt_event
);
390 HANDLE hEvent
= current
->interrupt_event
;
391 LeaveCriticalSection (¤t
->interrupt_mutex
);
396 _Jv_ThreadInterrupt (_Jv_Thread_t
*data
)
398 EnterCriticalSection (&data
->interrupt_mutex
);
399 ensure_interrupt_event_initialized (data
->interrupt_event
);
400 data
->thread_obj
->interrupt_flag
= true;
401 SetEvent (data
->interrupt_event
);
402 LeaveCriticalSection (&data
->interrupt_mutex
);