thread01.c

来自「开放源码的编译器open watcom 1.6.0版的源代码」· C语言 代码 · 共 91 行

#include <malloc.h>
#include <process.h>
#include <stdio.h>
#include <stddef.h>

#include "fail.h"

#if defined( __NT__ ) && defined( __386__ ) && ( __WATCOM_REVISION__ >= 8 )
    #define WIN32_LEAN_AND_MEAN
    #include <windows.h>
    #define TID			DWORD

static volatile int	NumThreads;
static volatile int	HoldThreads;
static	HANDLE	ThreadSem;

#define	STACK_SIZE	8192
#define _THREADID (*_threadid)

unsigned	__MaxThreads = { 4 };

typedef void (*PFUN)( void );

__declspec(thread) int file_integer = 1;


static	void	a_thread( void *args ) {
/**************************************/

    int		i;
    static __declspec(thread) int auto_integer = 100;

    args = args;

    while( HoldThreads ) {
	Sleep( 0 );
    }
    auto_integer++;
    if( auto_integer != 101 ) {
	printf( "auto_integer is not local to this thread: %d\n", _THREADID );
	_fail;
    }
    file_integer++;
    if( file_integer != 2 ) {
	printf( "file_integer is not local to this thread: %d\n", _THREADID );
	_fail;
    }
    WaitForSingleObject( ThreadSem, -1 );
    --NumThreads;
    ReleaseMutex( ThreadSem );
}

void	test() {
/**************/
    int		i;
    TID 	tid;
    unsigned	start_count;

    start_count = __MaxThreads;

    NumThreads = 0;
    HoldThreads = 1;
    ThreadSem = CreateMutex( NULL, FALSE, NULL );
    /* main thread counts as 1 */
    for( i = 2; i <= start_count; ++i ) {
	tid = (TID)_beginthread( a_thread, STACK_SIZE, 0 );
	if( tid == (TID)-1 ) {
	    printf( "creation of thread %d failed\n", i );
	    _fail;
	} else {
	    ++NumThreads;
	}
    }
    HoldThreads = 0;
    while( NumThreads != 0 ) {
	Sleep( 0 );
    }
    CloseHandle( ThreadSem );
}

#else
#define test()
#endif


int main()
{
    test();
    _PASS;
}