thread_pthreads.c

来自「CS架构的多平台的GUI系统」· C语言 代码 · 共 297 行

/***************************************************************************
    begin                : Thu Mar 25 2004
    copyright            : (C) 2004 - 2005 by Alper Akcan
    email                : [e-mail]
 ***************************************************************************/

/***************************************************************************
 *                                                                         *
 *   This program is free software; you can redistribute it and/or modify  *
 *   it under the terms of the GNU Lesser General Public License as        *
 *   published by the Free Software Foundation; either version 2.1 of the  *
 *   License, or (at your option) any later version.                       *
 *                                                                         *
 ***************************************************************************/

#include <pthread.h>

#if defined(PLATFORM_MINGW)
#include <windows.h>
#endif

#if defined(THREAD_MUTEX_EMULATION)

#include <semaphore.h>
struct s_thread_sem_s {
	sem_t *sem;
	sem_t sem_data;
};

#include "thread_mutex_emul.c"

static int s_thread_pthreads_sem_create (s_thread_sem_t *sem, int initial)
{
	if (sem == NULL) {
		goto err;
	}
	if (sem_init(&sem->sem_data, 0, initial) < 0) {
		goto err;
	}
	sem->sem = &sem->sem_data;
	return 0;
err:	return -1;
}

static int s_thread_pthreads_sem_destroy (s_thread_sem_t *sem)
{
	if (sem == NULL) {
		goto err;
	}
	sem_destroy(sem->sem);
	return 0;
err:	return -1;
}

static int s_thread_pthreads_sem_wait (s_thread_sem_t *sem)
{
	if (sem == NULL) {
		goto err;
	}
	if (sem_wait(sem->sem) < 0) {
		goto err;
	}
	return 0;
err:	return -1;
}

static int s_thread_pthreads_sem_wait_timeout (s_thread_sem_t *sem, int msec)
{
	unsigned int psec;
	signed int *ptout;

	if (sem == NULL) {
		return -1;
	}
	psec = (unsigned int) msec;
	ptout = &psec;

	do {
		if (sem_trywait(sem->sem) == 0) {
			break;
		}
		usleep(100);
		*ptout -= 100;
	} while (*ptout > 0);
	if (*ptout < 0) {
		return 1;
	}
	return 0;
}

static int s_thread_pthreads_sem_post (s_thread_sem_t *sem)
{
	if (sem == NULL) {
		goto err;
	}
	if (sem_post(sem->sem) < 0) {
		goto err;
	}
	return 0;
err:	return -1;
}

#else /* THREAD_MUTEX_EMULATION */

struct s_thread_cond_s {
	pthread_cond_t cond;
};

struct s_thread_mutex_s {
	pthread_mutex_t mut;
};

static int s_thread_pthreads_mutex_init (s_thread_mutex_t *mut)
{
	return pthread_mutex_init(&(mut->mut), NULL);
}

static int s_thread_pthreads_mutex_destroy (s_thread_mutex_t *mut)
{
	return pthread_mutex_destroy(&(mut->mut));
}

static int s_thread_pthreads_mutex_lock (s_thread_mutex_t *mut)
{
	return pthread_mutex_lock(&(mut->mut));
}

static int s_thread_pthreads_mutex_trylock (s_thread_mutex_t *mut)
{
	int ret;
	ret = pthread_mutex_trylock(&(mut->mut));
	if (ret == EBUSY) {
		ret = 1;
	}
	return ret;
}

static int s_thread_pthreads_mutex_unlock (s_thread_mutex_t *mut)
{
	return pthread_mutex_unlock(&(mut->mut));
}

static int s_thread_pthreads_cond_init (s_thread_cond_t *cond)
{
	return pthread_cond_init(&(cond->cond), NULL);
}

static int s_thread_pthreads_cond_destroy (s_thread_cond_t *cond)
{
	return pthread_cond_destroy(&(cond->cond));
}

static int s_thread_pthreads_cond_signal (s_thread_cond_t *cond)
{
	return pthread_cond_signal(&(cond->cond));
}

static int s_thread_pthreads_cond_broadcast (s_thread_cond_t *cond)
{
	return pthread_cond_broadcast(&(cond->cond));
}

static int s_thread_pthreads_cond_wait (s_thread_cond_t *cond, s_thread_mutex_t *mut)
{
	return pthread_cond_wait(&(cond->cond), &(mut->mut));
}

static int s_thread_pthreads_cond_timedwait (s_thread_cond_t *cond, s_thread_mutex_t *mut, int msec)
{
	int ret;
	struct timespec tspec;

#if 0
	struct timeval tval;
	gettimeofday(&tval, NULL);
	tspec.tv_sec = tval.tv_sec + (msec / 1000);
	tspec.tv_nsec = (tval.tv_usec + (msec % 1000) * 1000) * 1000;
#else
	long long tval;
	tval = s_gettimeofday();
	tspec.tv_sec = (tval / 1000) + (msec / 1000);
	tspec.tv_nsec = ((tval % 1000) + (msec % 1000)) * 1000 * 1000;
#endif

        if (tspec.tv_nsec > 1000000000) {
		tspec.tv_sec += 1;
		tspec.tv_nsec -= 1000000000;
	}

again:	ret = pthread_cond_timedwait(&(cond->cond), &(mut->mut), &tspec);
	switch (ret) {
		case EINTR:
			goto again;
			break;
		case ETIMEDOUT:
			ret = 1;
			break;
		case 0:
			break;
		default:
			ret = -1;
			break;
	}
	return ret;
}

#endif

struct s_thread_s {
	pthread_t tid;
};

static int s_thread_pthreads_thread_create (s_thread_t *tid, void * (*f) (void *), void *farg)
{
        int ret;
	pthread_attr_t attr;

	pthread_attr_init(&attr);
	pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_JOINABLE);
	ret = pthread_create(&(tid->tid), &attr, f, farg);
	pthread_attr_destroy(&attr);

	return ret;
}

static int s_thread_pthreads_thread_cancel (s_thread_t *tid)
{
	return pthread_cancel(tid->tid);
}

static int s_thread_pthreads_thread_join (s_thread_t *tid, void **ret)
{
	return pthread_join(tid->tid, ret);
}

static int s_thread_pthreads_thread_self (void)
{
#if defined(PLATFORM_MINGW)
	return pthread_self().x;
#else
	return (int) pthread_self();
#endif
}

static void s_thread_pthreads_thread_exit (void *ret)
{
	pthread_exit(ret);
}

static s_thread_api_t s_thread_pthreads = {
#if defined(THREAD_MUTEX_EMULATION)
	s_thread_pthreads_sem_create,
	s_thread_pthreads_sem_destroy,
	s_thread_pthreads_sem_wait,
	s_thread_pthreads_sem_wait_timeout,
	s_thread_pthreads_sem_post,

	s_thread_emul_mutex_init,
	s_thread_emul_mutex_destroy,
	s_thread_emul_mutex_lock,
	s_thread_emul_mutex_trylock,
	s_thread_emul_mutex_unlock,

	s_thread_emul_cond_init,
	s_thread_emul_cond_destroy,
	s_thread_emul_cond_signal,
	s_thread_emul_cond_broadcast,
	s_thread_emul_cond_wait,
	s_thread_emul_cond_timedwait,
#else
	NULL,
	NULL,
	NULL,
	NULL,
	NULL,

	s_thread_pthreads_mutex_init,
	s_thread_pthreads_mutex_destroy,
	s_thread_pthreads_mutex_lock,
	s_thread_pthreads_mutex_trylock,
	s_thread_pthreads_mutex_unlock,

	s_thread_pthreads_cond_init,
	s_thread_pthreads_cond_destroy,
	s_thread_pthreads_cond_signal,
	s_thread_pthreads_cond_broadcast,
	s_thread_pthreads_cond_wait,
	s_thread_pthreads_cond_timedwait,
#endif

	s_thread_pthreads_thread_create,
	s_thread_pthreads_thread_cancel,
	s_thread_pthreads_thread_join,
	s_thread_pthreads_thread_self,
	s_thread_pthreads_thread_exit,
};