ptwrapper.c
No OneTemporary
Actions

Subscribers

None

File Metadata

	/*
	* $Header: /u/gcmpack/MITgcm/eesupp/src/ptwrapper.c,v 1.1 2004/08/29 17:13:24 edhill Exp $
	* $Name: $
	*
	*
	* A PTHREADS convenience wrapper intended primarily for use with
	* gcc/g77 which does not support an "automatic" (here, meant as a
	* compiler-supported) threading mechanism.
	*
	*/

	#ifdef HAVE_PTHREADS

	#include <stdlib.h>
	#include <unistd.h>
	#include <sys/stat.h>
	#include <sys/types.h>
	#include <sys/wait.h>
	#include <errno.h>
	#include <pthread.h>


	void ptreentry_(int* myThid);

	pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
	int num_threads = 0;

	void *
	threadfunc(void *parm)
	{
	int myThid;
	int rc;

	rc = pthread_mutex_lock(&mutex);
	num_threads++;
	myThid = num_threads;
	rc = pthread_mutex_unlock(&mutex);
	ptreentry_(&myThid);
	}

	void
	ptinit_(int* nthreads)
	{
	int i,j;
	int rc;
	pthread_t threadids[10];
	pthread_attr_t pta;

	pthread_attr_init(&pta);
	pthread_attr_setdetachstate(&pta, PTHREAD_CREATE_JOINABLE);

	/* start the threads */
	for (i=0; i<(*nthreads); i++)
	rc = pthread_create(&threadids[i], &pta, threadfunc, NULL);

	/* wait on thread termination */
	for (i=0; i<(*nthreads); i++)
	rc = pthread_join(threadids[i], NULL);
	}

	#endif /* HAVE_PTHREADS */