vp8/common/threading.h

   1 /*
   2  *  Copyright (c) 2010 The WebM project authors. All Rights Reserved.
   3  *
   4  *  Use of this source code is governed by a BSD-style license
   5  *  that can be found in the LICENSE file in the root of the source
   6  *  tree. An additional intellectual property rights grant can be found
   7  *  in the file PATENTS.  All contributing project authors may
   8  *  be found in the AUTHORS file in the root of the source tree.
   9  */
  10
  11
  12 #ifndef _PTHREAD_EMULATION
  13 #define _PTHREAD_EMULATION
  14
  15 #define VPXINFINITE 10000       /* 10second. */
  16
  17 #if CONFIG_OS_SUPPORT && CONFIG_MULTITHREAD
  18
  19 /* Thread management macros */
  20 #ifdef _WIN32
  21 /* Win32 */
  22 #define _WIN32_WINNT 0x500 /* WINBASE.H - Enable signal_object_and_wait */
  23 #include <process.h>
  24 #include <windows.h>
  25 #define THREAD_FUNCTION DWORD WINAPI
  26 #define THREAD_FUNCTION_RETURN DWORD
  27 #define THREAD_SPECIFIC_INDEX DWORD
  28 #define pthread_t HANDLE
  29 #define pthread_attr_t DWORD
  30 #define pthread_create(thhandle,attr,thfunc,tharg) (int)((*thhandle=(HANDLE)_beginthreadex(NULL,0,(unsigned int (__stdcall *)(void *))thfunc,tharg,0,NULL))==NULL)
  31 #define pthread_join(thread, result) ((WaitForSingleObject((thread),VPXINFINITE)!=WAIT_OBJECT_0) || !CloseHandle(thread))
  32 #define pthread_detach(thread) if(thread!=NULL)CloseHandle(thread)
  33 #define thread_sleep(nms) Sleep(nms)
  34 #define pthread_cancel(thread) terminate_thread(thread,0)
  35 #define ts_key_create(ts_key, destructor) {ts_key = TlsAlloc();};
  36 #define pthread_getspecific(ts_key) TlsGetValue(ts_key)
  37 #define pthread_setspecific(ts_key, value) TlsSetValue(ts_key, (void *)value)
  38 #define pthread_self() GetCurrentThreadId()
  39 #else
  40 #ifdef __APPLE__
  41 #include <mach/mach_init.h>
  42 #include <mach/semaphore.h>
  43 #include <mach/task.h>
  44 #include <time.h>
  45 #include <unistd.h>
  46
  47 #else
  48 #include <semaphore.h>
  49 #endif
  50
  51 #include <pthread.h>
  52 /* pthreads */
  53 /* Nearly everything is already defined */
  54 #define THREAD_FUNCTION void *
  55 #define THREAD_FUNCTION_RETURN void *
  56 #define THREAD_SPECIFIC_INDEX pthread_key_t
  57 #define ts_key_create(ts_key, destructor) pthread_key_create (&(ts_key), destructor);
  58 #endif
  59
  60 /* Syncrhronization macros: Win32 and Pthreads */
  61 #ifdef _WIN32
  62 #define sem_t HANDLE
  63 #define pause(voidpara) __asm PAUSE
  64 #define sem_init(sem, sem_attr1, sem_init_value) (int)((*sem = CreateEvent(NULL,FALSE,FALSE,NULL))==NULL)
  65 #define sem_wait(sem) (int)(WAIT_OBJECT_0 != WaitForSingleObject(*sem,VPXINFINITE))
  66 #define sem_post(sem) SetEvent(*sem)
  67 #define sem_destroy(sem) if(*sem)((int)(CloseHandle(*sem))==TRUE)
  68 #define thread_sleep(nms) Sleep(nms)
  69
  70 #else
  71
  72 #ifdef __APPLE__
  73 #define sem_t semaphore_t
  74 #define sem_init(X,Y,Z) semaphore_create(mach_task_self(), X, SYNC_POLICY_FIFO, Z)
  75 #define sem_wait(sem) (semaphore_wait(*sem) )
  76 #define sem_post(sem) semaphore_signal(*sem)
  77 #define sem_destroy(sem) semaphore_destroy(mach_task_self(),*sem)
  78 #define thread_sleep(nms) /* { struct timespec ts;ts.tv_sec=0; ts.tv_nsec = 1000*nms;nanosleep(&ts, NULL);} */
  79 #else
  80 #include <unistd.h>
  81 #include <sched.h>
  82 #define thread_sleep(nms) sched_yield();/* {struct timespec ts;ts.tv_sec=0; ts.tv_nsec = 1000*nms;nanosleep(&ts, NULL);} */
  83 #endif
  84 /* Not Windows. Assume pthreads */
  85
  86 #endif
  87
  88 #if ARCH_X86 || ARCH_X86_64
  89 #include "vpx_ports/x86.h"
  90 #else
  91 #define x86_pause_hint()
  92 #endif
  93
  94 #endif /* CONFIG_OS_SUPPORT && CONFIG_MULTITHREAD */
  95
  96 #endif