1 // win32-threads.cc - interface between libjava and Win32 threads.
3 /* Copyright (C) 1998, 1999 Red Hat, Inc.
5 This file is part of libgcj.
7 This software is copyrighted work licensed under the terms of the
8 Libgcj License. Please consult the file "LIBGCJ_LICENSE" for
13 // If we're using the Boehm GC, then we need to override some of the
14 // thread primitives. This is fairly gross.
18 #include <boehm-config.h>
21 #endif /* HAVE_BOEHM_GC */
25 #include <java/lang/Thread.h>
26 #include <java/lang/System.h>
34 // This is used to implement thread startup.
37 _Jv_ThreadStartFunc *method;
41 // Controls access to the variable below
42 static HANDLE daemon_mutex;
43 static HANDLE daemon_cond;
44 // Number of non-daemon threads - _Jv_ThreadWait returns when this is 0
45 static int non_daemon_count;
47 // TLS key get Java object representing the thread
49 // TLS key to get _Jv_Thread_t* representing the thread
50 DWORD _Jv_ThreadDataKey;
53 // These are the flags that can appear in _Jv_Thread_t.
57 #define FLAG_START 0x01
59 #define FLAG_DAEMON 0x02
62 // Condition variables.
66 _Jv_CondWait (_Jv_ConditionVariable_t *cv, _Jv_Mutex_t *mu, jlong millis, jint nanos)
71 // FIXME: check for mutex ownership?
75 if((millis == 0) && (nanos > 0))
82 rval = WaitForSingleObject (*cv, time);
85 if (rval == WAIT_FAILED)
86 return _JV_NOT_OWNER; // FIXME?
96 _Jv_MutexLock (_Jv_Mutex_t *mu)
100 // FIXME: Are Win32 mutexs recursive? Should we use critical section objects
101 rval = WaitForSingleObject (*mu, INFINITE);
103 if (rval == WAIT_FAILED)
104 return GetLastError (); // FIXME: Map to errno?
105 else if (rval == WAIT_TIMEOUT)
116 _Jv_InitThreads (void)
118 _Jv_ThreadKey = TlsAlloc();
119 _Jv_ThreadDataKey = TlsAlloc();
120 daemon_mutex = CreateMutex(NULL, 0, NULL);
121 daemon_cond = CreateEvent(NULL, 0, 0, NULL);
122 non_daemon_count = 0;
126 _Jv_ThreadInitData (java::lang::Thread* obj)
128 _Jv_Thread_t *data = new _Jv_Thread_t;
130 data->thread_obj = obj;
136 _Jv_ThreadDestroyData (_Jv_Thread_t *data)
142 _Jv_ThreadSetPriority (_Jv_Thread_t *data, jint prio)
144 int actual = THREAD_PRIORITY_NORMAL;
146 if (data->flags & FLAG_START)
151 actual = THREAD_PRIORITY_TIME_CRITICAL;
154 actual = THREAD_PRIORITY_HIGHEST;
158 actual = THREAD_PRIORITY_ABOVE_NORMAL;
162 actual = THREAD_PRIORITY_NORMAL;
166 actual = THREAD_PRIORITY_BELOW_NORMAL;
169 actual = THREAD_PRIORITY_LOWEST;
172 actual = THREAD_PRIORITY_IDLE;
175 SetThreadPriority(data->handle, actual);
180 _Jv_ThreadRegister (_Jv_Thread_t *data)
182 TlsSetValue (_Jv_ThreadKey, data->thread_obj);
183 TlsSetValue (_Jv_ThreadDataKey, data);
187 _Jv_ThreadUnRegister ()
189 TlsSetValue (_Jv_ThreadKey, NULL);
190 TlsSetValue (_Jv_ThreadDataKey, NULL);
193 // This function is called when a thread is started. We don't arrange
194 // to call the `run' method directly, because this function must
196 static DWORD __stdcall
197 really_start (void* x)
199 struct starter *info = (struct starter *) x;
201 _Jv_ThreadRegister (info->data);
203 info->method (info->data->thread_obj);
205 if (! (info->data->flags & FLAG_DAEMON))
207 WaitForSingleObject (daemon_mutex, INFINITE);
209 if (! non_daemon_count)
210 PulseEvent (daemon_cond);
211 ReleaseMutex (daemon_mutex);
218 _Jv_ThreadStart (java::lang::Thread *thread, _Jv_Thread_t *data, _Jv_ThreadStartFunc *meth)
221 struct starter *info;
223 // Do nothing if thread has already started
224 if (data->flags & FLAG_START)
226 data->flags |= FLAG_START;
228 // FIXME: handle marking the info object for GC.
229 info = (struct starter *) _Jv_AllocBytes (sizeof (struct starter));
233 if (! thread->isDaemon ())
235 WaitForSingleObject (daemon_mutex, INFINITE);
237 ReleaseMutex (daemon_mutex);
240 data->flags |= FLAG_DAEMON;
242 HANDLE h = CreateThread(NULL, 0, really_start, info, 0, &id);
243 _Jv_ThreadSetPriority(data, thread->getPriority());
250 _Jv_ThreadWait (void)
252 WaitForSingleObject(daemon_mutex, INFINITE);
254 SignalObjectAndWait(daemon_mutex, daemon_cond, INFINITE, 0);
255 ReleaseMutex(daemon_mutex);
259 _Jv_ThreadInterrupt (_Jv_Thread_t *data)
261 MessageBox(NULL, "Unimplemented", "win32-threads.cc:_Jv_ThreadInterrupt", MB_OK);