thread.h

Go to the documentation of this file.

#ifndef RBIMPL_INTERN_THREAD_H                       /*-*-C++-*-vi:se ft=cpp:*/
#define RBIMPL_INTERN_THREAD_H
#include "ruby/internal/attr/nonnull.h"
#include "ruby/internal/cast.h"
#include "ruby/internal/config.h"
#include "ruby/internal/dllexport.h"
#include "ruby/internal/value.h"
 
RBIMPL_SYMBOL_EXPORT_BEGIN()
 
struct timeval;
 
/* thread.c */
 
void rb_thread_schedule(void);
 
int rb_thread_wait_fd(int fd);
 
int rb_thread_fd_writable(int fd);
 
void rb_thread_fd_close(int fd);
 
int rb_thread_alone(void);
 
void rb_thread_sleep(int sec);
 
void rb_thread_sleep_forever(void);
 
void rb_thread_sleep_deadly(void);
 
VALUE rb_thread_stop(void);
 
VALUE rb_thread_wakeup(VALUE thread);
 
VALUE rb_thread_wakeup_alive(VALUE thread);
 
VALUE rb_thread_run(VALUE thread);
 
VALUE rb_thread_kill(VALUE thread);
 
RBIMPL_ATTR_NONNULL((1))
VALUE rb_thread_create(VALUE (*f)(void *g), void *g);
 
void rb_thread_wait_for(struct timeval time);
 
VALUE rb_thread_current(void);
 
VALUE rb_thread_main(void);
 
VALUE rb_thread_local_aref(VALUE thread, ID key);
 
VALUE rb_thread_local_aset(VALUE thread, ID key, VALUE val);
 
void rb_thread_atfork(void);
 
void rb_thread_atfork_before_exec(void);
 
VALUE rb_exec_recursive(VALUE (*f)(VALUE g, VALUE h, int r), VALUE g, VALUE h);
 
VALUE rb_exec_recursive_paired(VALUE (*f)(VALUE g, VALUE h, int r), VALUE g, VALUE p, VALUE h);
 
VALUE rb_exec_recursive_outer(VALUE (*f)(VALUE g, VALUE h, int r), VALUE g, VALUE h);
 
VALUE rb_exec_recursive_paired_outer(VALUE (*f)(VALUE g, VALUE h, int r), VALUE g, VALUE p, VALUE h);
 
typedef void rb_unblock_function_t(void *);
 
typedef VALUE rb_blocking_function_t(void *);
 
void rb_thread_check_ints(void);
 
int rb_thread_interrupted(VALUE thval);
 
#define RUBY_UBF_IO RBIMPL_CAST((rb_unblock_function_t *)-1)
 
#define RUBY_UBF_PROCESS RBIMPL_CAST((rb_unblock_function_t *)-1)
 
/* thread_sync.c */
 
VALUE rb_mutex_new(void);
 
VALUE rb_mutex_locked_p(VALUE mutex);
 
VALUE rb_mutex_trylock(VALUE mutex);
 
VALUE rb_mutex_lock(VALUE mutex);
 
VALUE rb_mutex_unlock(VALUE mutex);
 
VALUE rb_mutex_sleep(VALUE self, VALUE timeout);
 
VALUE rb_mutex_synchronize(VALUE mutex, VALUE (*func)(VALUE arg), VALUE arg);
 
RBIMPL_SYMBOL_EXPORT_END()
 
#endif /* RBIMPL_INTERN_THREAD_H */