1

/* $Id$ */

     2

     3

#include "stdafx.h"

     4

#include "thread.h"

     5

#include <stdlib.h>

     6

     7

#if defined(__AMIGA__) || defined(__MORPHOS__)

     8

Thread* OTTDCreateThread(ThreadFunc function, void* arg) { return NULL; }

     9

void OTTDJoinThread(Thread*) {}

    10

    11

    12

#elif defined(__OS2__)

    13

    14

#define INCL_DOS

    15

#include <os2.h>

    16

#include <process.h>

    17

    18

struct Thread {

    19

	TID thread;

    20

};

    21

    22

Thread* OTTDCreateThread(ThreadFunc function, void* arg)

    23

{

    24

	Thread* t = malloc(sizeof(*t));

    25

    26

	if (t == NULL) return NULL;

    27

    28

	t->thread = _beginthread(function, NULL, 32768, arg);

    29

	if (t->thread != -1) {

    30

		return t;

    31

	} else {

    32

		free(t);

    33

		return NULL;

    34

	}

    35

}

    36

    37

void OTTDJoinThread(Thread* t)

    38

{

    39

	if (t == NULL) return;

    40

    41

	DosWaitThread(&t->thread, DCWW_WAIT);

    42

	free(t);

    43

}

    44

    45

    46

#elif defined(UNIX)

    47

    48

#include <pthread.h>

    49

    50

struct Thread {

    51

	pthread_t thread;

    52

};

    53

    54

Thread* OTTDCreateThread(ThreadFunc function, void* arg)

    55

{

    56

	Thread* t = malloc(sizeof(*t));

    57

    58

	if (t == NULL) return NULL;

    59

    60

	if (pthread_create(&t->thread, NULL, (void* (*)(void*))function, arg) == 0) {

    61

		return t;

    62

	} else {

    63

		free(t);

    64

		return NULL;

    65

	}

    66

}

    67

    68

void OTTDJoinThread(Thread* t)

    69

{

    70

	if (t == NULL) return;

    71

    72

	pthread_join(t->thread, NULL);

    73

	free(t);

    74

}

    75

    76

    77

#elif defined(WIN32)

    78

    79

#include <windows.h>

    80

    81

struct Thread {

    82

	HANDLE thread;

    83

};

    84

    85

Thread* OTTDCreateThread(ThreadFunc function, void* arg)

    86

{

    87

	Thread* t = malloc(sizeof(*t));

    88

	DWORD dwThreadId;

    89

    90

	if (t == NULL) return NULL;

    91

    92

	t->thread = CreateThread(

    93

		NULL, 0, (LPTHREAD_START_ROUTINE)function, arg, 0, &dwThreadId

    94

	);

    95

    96

	if (t->thread != NULL) {

    97

		return t;

    98

	} else {

    99

		free(t);

   100

		return NULL;

   101

	}

   102

}

   103

   104

void OTTDJoinThread(Thread* t)

   105

{

   106

	if (t == NULL) return;

   107

   108

	WaitForSingleObject(t->thread, INFINITE);

   109

	CloseHandle(t->thread);

   110

	free(t);

   111

}

   112

#endif