for (int i = 0; i <= MAX_THREADS; i++)
{
threads[i].is_searching = false;
- threads[i].do_sleep = true;
+ threads[i].do_sleep = (i != 0); // Avoid a race with start_thinking()
threads[i].threadID = i;
#if defined(_MSC_VER)
- threads[i].handle = CreateThread(NULL, 0, start_routine, (LPVOID)&threads[i], 0, NULL);
+ threads[i].handle = CreateThread(NULL, 0, start_routine, &threads[i], 0, NULL);
bool ok = (threads[i].handle != NULL);
#else
- bool ok = !pthread_create(&threads[i].handle, NULL, start_routine, (void*)&threads[i]);
+ bool ok = !pthread_create(&threads[i].handle, NULL, start_routine, &threads[i]);
#endif
if (!ok)
// Wait for thread termination
#if defined(_MSC_VER)
- WaitForSingleObject(threads[i].handle, 0);
+ WaitForSingleObject(threads[i].handle, INFINITE);
CloseHandle(threads[i].handle);
#else
pthread_join(threads[i].handle, NULL);
// Thread::timer_loop() is where the timer thread waits maxPly milliseconds and
// then calls do_timer_event(). If maxPly is 0 thread sleeps until is woken up.
-extern void do_timer_event();
+extern void check_time();
void Thread::timer_loop() {
lock_grab(&sleepLock);
timed_wait(&sleepCond, &sleepLock, maxPly ? maxPly : INT_MAX);
lock_release(&sleepLock);
- do_timer_event();
+ check_time();
}
}
cond_signal(&main.sleepCond); // Wake up main thread and start searching
if (!asyncMode)
- cond_wait(&sleepCond, &main.sleepLock);
+ while (!main.do_sleep)
+ cond_wait(&sleepCond, &main.sleepLock);
lock_release(&main.sleepLock);
}