suzanne.soy/racket
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

futures bug fix

Browse Source
This commit is contained in:
Matthew Flatt 2011-12-02 08:04:20 -07:00
parent 2e54a89773
commit efe165aeac
1 changed files with 6 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/racket/src/future.c
View File

@ -2343,15 +2343,13 @@ void scheme_check_future_work()
if (capture_future_continuation(fs, ft, storage, 1)) {
/* capture performs mzrt_mutex_lock(fs->future_mutex) on success. */
/* Signal the waiting worker thread that it
can continue doing other things: */
ft->can_continue_sema = can_continue_sema;
if (ft->can_continue_sema) {
mzrt_sema_post(ft->can_continue_sema);
ft->can_continue_sema = NULL;
}
mzrt_mutex_unlock(fs->future_mutex);
}
/* Signal the waiting worker thread that it can continue, since
we either captured the continuation or the result became
available meanwhile: */
if (can_continue_sema)
mzrt_sema_post(can_continue_sema);
} else
break;
}
@ -3020,6 +3018,7 @@ static void invoke_rtcall(Scheme_Future_State * volatile fs, future_t * volatile
} else {
/* Signal the waiting worker thread that it
can continue running machine code */
future->want_lw = 0;
mzrt_sema_post(future->can_continue_sema);
future->can_continue_sema = NULL;
mzrt_mutex_unlock(fs->future_mutex);