sag_connectivity_threading.h

Go to the documentation of this file.

/*
 * Title:        sag_connectivity_threading.hpp
 * Description:  A cross-platform threading implementation for old compilers
 * $Copyright (c) 2015-2016 Software AG, Darmstadt, Germany and/or Software AG USA Inc., Reston, VA, USA, and/or its subsidiaries and/or its affiliates and/or their licensors.$
 * Use, reproduction, transfer, publication or disclosure is prohibited except as specifically provided for in your License Agreement with Software AG
 * @Version:     $Id: sag_connectivity_threading.h 272471 2016-01-08 15:52:33Z cree $
 */

#ifndef _SAG_CONNECTIVITY_THREADS_HPP_
#define _SAG_CONNECTIVITY_THREADS_HPP_

#if defined(_WIN32) || defined(__WIN32) || defined(WIN32)

// Windows implementation using CriticalSections and _beginthreadex

#include <stdarg.h>
#include <windef.h>
#include <winbase.h>
#include <process.h>
#include <io.h>

#define SAG_MUTEX_LOCK(m) EnterCriticalSection(&m)
#define SAG_MUTEX_UNLOCK(m) LeaveCriticalSection(&m)
#define SAG_MUTEX_INIT(m) InitializeCriticalSection(&m)
#define SAG_MUTEX_DESTROY(m) DeleteCriticalSection(&m)
#define SAG_MUTEX_T CRITICAL_SECTION

#define SAG_SEMA_WAIT(s) WaitForSingleObject(s, INFINITE)
#define SAG_SEMA_POST(s) ReleaseSemaphore(s, 1, NULL)
#define SAG_SEMA_INIT(s) s = CreateSemaphore(NULL, 0, 0x7FFFFFFF, NULL)
#define SAG_SEMA_DESTROY(s) CloseHandle(s)
#define SAG_SEMA_T HANDLE

#define SAG_THREAD_CREATE(id, func, params) (!(id = (HANDLE)_beginthreadex(NULL, 0, func, params, 0, NULL)))
#define SAG_THREAD_JOIN(id) WaitForSingleObject(id, INFINITE)
#define SAG_THREAD_RETURN return 0;
#define SAG_THREAD_T HANDLE 
#define SAG_THREAD_RET_T unsigned int __stdcall 

#else

// Unix implementation using pthreads

#include <pthread.h>
#include <semaphore.h>
#include <unistd.h>
#include <signal.h>


#define SAG_MUTEX_LOCK(m) pthread_mutex_lock(&m)
#define SAG_MUTEX_UNLOCK(m) pthread_mutex_unlock(&m)
#define SAG_MUTEX_INIT(m) pthread_mutex_init(&m, NULL)
#define SAG_MUTEX_DESTROY(m) pthread_mutex_destroy(&m)
#define SAG_MUTEX_T pthread_mutex_t

#define SAG_SEMA_WAIT(s) {while (sem_wait(&s));}
#define SAG_SEMA_POST(s) sem_post(&s)
#define SAG_SEMA_INIT(s) sem_init(&s, 0, 0)
#define SAG_SEMA_DESTROY(s) sem_destroy(&s)
#define SAG_SEMA_T sem_t

#define SAG_THREAD_CREATE(id, func, params) pthread_create(& id, NULL, func, params)
#define SAG_THREAD_JOIN(id) pthread_join(id, NULL)
#define SAG_THREAD_RETURN return NULL;
#define SAG_THREAD_T pthread_t
#define SAG_THREAD_RET_T void*


#endif


#endif // _SAG_CONNECTIVITY_THREADS_HPP_