X-Git-Url: http://repo.macrolet.net/gitweb/?a=blobdiff_plain;ds=sidebyside;f=src%2Fruntime%2Fthread.h;h=f8ec4e71b67822d9ab64351aa62924bb60c9bdae;hb=409fcc671231b594ec010adf683f72a871ec1d6a;hp=074edeca2f696ebbf5ebbf223f64b1342836f648;hpb=1d33d240c6f1385157c7d71f681911f7387ddf32;p=sbcl.git diff --git a/src/runtime/thread.h b/src/runtime/thread.h index 074edec..f8ec4e7 100644 --- a/src/runtime/thread.h +++ b/src/runtime/thread.h @@ -23,6 +23,39 @@ struct alloc_region { }; #define STATE_SUSPENDED (make_fixnum(2)) #define STATE_DEAD (make_fixnum(3)) +#ifdef LISP_FEATURE_SB_THREAD + +/* Only access thread state with blockables blocked. */ +static inline lispobj +thread_state(struct thread *thread) +{ + lispobj state; + pthread_mutex_lock(thread->state_lock); + state = thread->state; + pthread_mutex_unlock(thread->state_lock); + return state; +} + +static inline void +set_thread_state(struct thread *thread, lispobj state) +{ + pthread_mutex_lock(thread->state_lock); + thread->state = state; + pthread_cond_broadcast(thread->state_cond); + pthread_mutex_unlock(thread->state_lock); +} + +static inline void +wait_for_thread_state_change(struct thread *thread, lispobj state) +{ + pthread_mutex_lock(thread->state_lock); + while (thread->state == state) + pthread_cond_wait(thread->state_cond, thread->state_lock); + pthread_mutex_unlock(thread->state_lock); +} + +#endif + #define THREAD_SLOT_OFFSET_WORDS(c) \ (offsetof(struct thread,c)/(sizeof (struct thread *))) @@ -31,7 +64,7 @@ union per_thread_data { lispobj dynamic_values[1]; /* actually more like 4000 or so */ }; -extern struct thread * volatile all_threads; +extern struct thread *all_threads; extern int dynamic_values_bytes; #if defined(LISP_FEATURE_DARWIN)