mirror of
https://github.com/ruby/ruby.git
synced 2022-11-09 12:17:21 -05:00
4d9c23772f
`acquired' was an old boolean variable, but nowadays it is a rb_thread_t pointer; "gvl.owner" seems like a more appropriate name. And document the contended path including waitq, timer, and timer_err. git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@64581 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
75 lines
2 KiB
C
75 lines
2 KiB
C
/**********************************************************************
|
|
|
|
thread_pthread.h -
|
|
|
|
$Author$
|
|
|
|
Copyright (C) 2004-2007 Koichi Sasada
|
|
|
|
**********************************************************************/
|
|
|
|
#ifndef RUBY_THREAD_PTHREAD_H
|
|
#define RUBY_THREAD_PTHREAD_H
|
|
|
|
#ifdef HAVE_PTHREAD_NP_H
|
|
#include <pthread_np.h>
|
|
#endif
|
|
|
|
#define RB_NATIVETHREAD_LOCK_INIT PTHREAD_MUTEX_INITIALIZER
|
|
#define RB_NATIVETHREAD_COND_INIT PTHREAD_COND_INITIALIZER
|
|
|
|
typedef pthread_cond_t rb_nativethread_cond_t;
|
|
|
|
typedef struct native_thread_data_struct {
|
|
union {
|
|
struct list_node ubf;
|
|
struct list_node gvl;
|
|
} node;
|
|
#if defined(__GLIBC__) || defined(__FreeBSD__)
|
|
union
|
|
#else
|
|
/*
|
|
* assume the platform condvars are badly implemented and have a
|
|
* "memory" of which mutex they're associated with
|
|
*/
|
|
struct
|
|
#endif
|
|
{
|
|
rb_nativethread_cond_t intr; /* th->interrupt_lock */
|
|
rb_nativethread_cond_t gvlq; /* vm->gvl.lock */
|
|
} cond;
|
|
} native_thread_data_t;
|
|
|
|
#undef except
|
|
#undef try
|
|
#undef leave
|
|
#undef finally
|
|
|
|
typedef struct rb_global_vm_lock_struct {
|
|
/* fast path */
|
|
const struct rb_thread_struct *owner;
|
|
rb_nativethread_lock_t lock; /* AKA vm->gvl.lock */
|
|
|
|
/*
|
|
* slow path, protected by vm->gvl.lock
|
|
* - @waitq - FIFO queue of threads waiting for GVL
|
|
* - @timer - it handles timeslices for @owner. It is any one thread
|
|
* in @waitq, there is no @timer if @waitq is empty, but always
|
|
* a @timer if @waitq has entries
|
|
* - @timer_err tracks timeslice limit, the timeslice only resets
|
|
* when pthread_cond_timedwait returns ETIMEDOUT, so frequent
|
|
* switching between contended/uncontended GVL won't reset the
|
|
* timer.
|
|
*/
|
|
struct list_head waitq; /* <=> native_thread_data_t.node.ubf */
|
|
const struct rb_thread_struct *timer;
|
|
int timer_err;
|
|
|
|
/* yield */
|
|
rb_nativethread_cond_t switch_cond;
|
|
rb_nativethread_cond_t switch_wait_cond;
|
|
int need_yield;
|
|
int wait_yield;
|
|
} rb_global_vm_lock_t;
|
|
|
|
#endif /* RUBY_THREAD_PTHREAD_H */
|