From c280e280ba7528cc5fb88ae0be341d81f3b45e0a Mon Sep 17 00:00:00 2001 From: Tavian Barnes Date: Sun, 9 May 2010 21:41:43 -0600 Subject: New dmnsn_new_thread() function. Two advantages: first, waiters are guaranteed to wake if a dmnsn_error() cancels a thread. Second, the thread library is fully abstracted over by threads.{c,h} and progress.{c,h} now, though raytrace.c is still using pthread_create() directly. --- libdimension/threads.c | 58 ++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 58 insertions(+) create mode 100644 libdimension/threads.c (limited to 'libdimension/threads.c') diff --git a/libdimension/threads.c b/libdimension/threads.c new file mode 100644 index 0000000..5450ecc --- /dev/null +++ b/libdimension/threads.c @@ -0,0 +1,58 @@ +/************************************************************************* + * Copyright (C) 2010 Tavian Barnes * + * * + * This file is part of The Dimension Library. * + * * + * The Dimension Library 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 3 of the * + * License, or (at your option) any later version. * + * * + * The Dimension Library is distributed in the hope that it will be * + * useful, but WITHOUT ANY WARRANTY; without even the implied warranty * + * of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * + * Lesser General Public License for more details. * + * * + * You should have received a copy of the GNU Lesser General Public * + * License along with this program. If not, see * + * . * + *************************************************************************/ + +#include "dimension_impl.h" + +typedef struct dmnsn_thread_payload { + dmnsn_thread_fn *thread_fn; + void *arg; + dmnsn_progress *progress; +} dmnsn_thread_payload; + +static void +dmnsn_thread_cleanup(void *arg) +{ + dmnsn_progress *progress = arg; + dmnsn_done_progress(progress); +} + +static void * +dmnsn_thread(void *arg) +{ + dmnsn_thread_payload *payload = arg; + int *ret; + pthread_cleanup_push(&dmnsn_thread_cleanup, payload->progress); + ret = dmnsn_malloc(sizeof(ret)); + *ret = (*payload->thread_fn)(payload->arg); + pthread_cleanup_pop(1); + return ret; +} + +int +dmnsn_new_thread(dmnsn_progress *progress, const pthread_attr_t *attr, + dmnsn_thread_fn *thread_fn, void *arg) +{ + dmnsn_thread_payload *payload = dmnsn_malloc(sizeof(dmnsn_thread_payload)); + payload->thread_fn = thread_fn; + payload->arg = arg; + payload->progress = progress; + + return pthread_create(&progress->thread, attr, &dmnsn_thread, payload); +} -- cgit v1.2.3