threads.h

Go to the documentation of this file.

/* threads.h -- header for threads library */
#pragma once
#ifndef _THR_THREADS_H
#define _THR_THREADS_H
#ifndef RC_INVOKED
#include <thr/xthreads.h>

 #pragma pack(push,_CRT_PACKING)
 #pragma warning(push,_STL_WARNING_LEVEL)
 #pragma warning(disable: _STL_DISABLED_WARNINGS)
 #pragma push_macro("new")
 #undef new

_EXTERN_C
enum {  /* return codes */
    thrd_success = _Thrd_success,
    thrd_nomem = _Thrd_nomem,
    thrd_timedout = _Thrd_timedout,
    thrd_busy = _Thrd_busy,
    thrd_error = _Thrd_error
    };

    /* threads */
typedef _Thrd_t thrd_t;
typedef _Thrd_start_t thrd_start_t;

#define thrd_create(thr, fun, arg)  _Thrd_create(thr, fun, arg)

#define thrd_detach(thr)        _Thrd_detach(thr)
#define thrd_exit(code)         _Thrd_exit(code)
#define thrd_join(thr, res)     _Thrd_join(thr, res)
#define thrd_sleep(tm)          _Thrd_sleep(tm)
#define thrd_yield              _Thrd_yield
#define thrd_equal(thr0, thr1)  _Thrd_equal(thr0, thr1)
#define thrd_current            _Thrd_current

    /* mutexes */
typedef _Mtx_imp_t mtx_t;
enum {  /* mutex types */
    mtx_plain = _Mtx_plain,
    mtx_try = _Mtx_try,
    mtx_timed = _Mtx_timed,
    mtx_recursive = _Mtx_recursive
    };

#define mtx_init(mtx, typ)      _Mtx_init(mtx, typ)
#define mtx_destroy(mtx)        _Mtx_destroy((*mtx))
#define mtx_current_owns(mtx)   _Mtx_current_owns((*mtx))
#define mtx_lock(mtx)           _Mtx_lock((*mtx))
#define mtx_trylock(mtx)        _Mtx_trylock((*mtx))
#define mtx_timedlock(mtx, tm)  _Mtx_timedlock((*mtx), tm)
#define mtx_unlock(mtx)         _Mtx_unlock((*mtx))

    /* condition variables */
typedef _Cnd_t cnd_t;

#define cnd_init(cnd)           _Cnd_init(cnd)
#define cnd_destroy(cnd)        _Cnd_destroy((*cnd))
#define cnd_timedwait(cnd, mtx, tm) \
    _Cnd_timedwait((*cnd), (*mtx), tm)
#define cnd_wait(cnd, mtx) \
    _Cnd_wait((*cnd), (*mtx))
#define cnd_broadcast(cnd)      _Cnd_broadcast((*cnd))
#define cnd_broadcast_at_thread_exit(cnd, mtx) \
    _Cnd_register_at_thread_exit((*cnd), (*mtx), 0)
#define cnd_signal(cnd)         _Cnd_signal((*cnd))

    /* thread specific storage */
typedef _Tss_t tss_t;
typedef _Tss_dtor_t tss_dtor_t;
#define TSS_DTOR_ITERATIONS _TSS_DTOR_ITERATIONS

#define tss_create(key, dtor)   _Tss_create(key, dtor)
#define tss_delete(key)         _Tss_delete(key)
#define tss_set(key, value)     _Tss_set(key, value)
#define tss_get(key)            _Tss_get(key)

    /* utility functions */
#define thread_abort    _Thread_abort

_END_EXTERN_C
 #pragma pop_macro("new")
 #pragma warning(pop)
 #pragma pack(pop)
#endif /* RC_INVOKED */
#endif  /* _THR_THREADS_H */

/*
 * This file is derived from software bearing the following
 * restrictions:
 *
 * (c) Copyright William E. Kempf 2001
 *
 * Permission to use, copy, modify, distribute and sell this
 * software and its documentation for any purpose is hereby
 * granted without fee, provided that the above copyright
 * notice appear in all copies and that both that copyright
 * notice and this permission notice appear in supporting
 * documentation. William E. Kempf makes no representations
 * about the suitability of this software for any purpose.
 * It is provided "as is" without express or implied warranty.
 */

/*
 * Copyright (c) by P.J. Plauger. All rights reserved.
 * Consult your license regarding permissions and restrictions.
V6.50:0009 */