X-Git-Url: https://git.netwichtig.de/gitweb/?a=blobdiff_plain;f=include%2Fthreadengine.h;h=e0ed9ec405b006b428c54afce1d32c3bc396267e;hb=9de86c34d41fcbcedf7b332746b7f0e8c37c7c45;hp=c11f2d817734d58a7de096b2836a8cf20b843a63;hpb=9b6337bec9b8adfcb1746c76be752334869ac997;p=user%2Fhenk%2Fcode%2Finspircd.git diff --git a/include/threadengine.h b/include/threadengine.h index c11f2d817..e0ed9ec40 100644 --- a/include/threadengine.h +++ b/include/threadengine.h @@ -1,36 +1,39 @@ -/* +------------------------------------+ - * | Inspire Internet Relay Chat Daemon | - * +------------------------------------+ +/* + * InspIRCd -- Internet Relay Chat Daemon * - * InspIRCd: (C) 2002-2009 InspIRCd Development Team - * See: http://wiki.inspircd.org/Credits + * Copyright (C) 2009 Daniel De Graaf + * Copyright (C) 2008 Craig Edwards * - * This program is free but copyrighted software; see - * the file COPYING for details. + * This file is part of InspIRCd. InspIRCd is free software: you can + * redistribute it and/or modify it under the terms of the GNU General Public + * License as published by the Free Software Foundation, version 2. * - * --------------------------------------------------- + * This program 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 General Public License for more + * details. + * + * You should have received a copy of the GNU General Public License + * along with this program. If not, see . */ -#ifndef __THREADENGINE__ -#define __THREADENGINE__ + +#ifndef THREADENGINE_H +#define THREADENGINE_H #include #include #include -#include "inspircd_config.h" +#include "config.h" #include "base.h" -#ifdef WINDOWS -#include "threadengines/threadengine_win32.h" -#endif - class ThreadData; /** Derive from this class to implement your own threaded sections of * code. Be sure to keep your code thread-safe and not prone to deadlocks * and race conditions if you MUST use threading! */ -class CoreExport Thread : public Extensible +class CoreExport Thread { private: /** Set to true when the thread is to exit @@ -55,6 +58,7 @@ class CoreExport Thread : public Extensible { } + /* If the thread is running, you MUST join BEFORE deletion */ virtual ~Thread(); /** Override this method to put your actual @@ -64,10 +68,11 @@ class CoreExport Thread : public Extensible /** Signal the thread to exit gracefully. */ - virtual void SetExitFlag() - { - ExitFlag = true; - } + virtual void SetExitFlag(); + + /** Join the thread (calls SetExitFlag and waits for exit) + */ + void join(); }; @@ -127,12 +132,12 @@ class CoreExport SocketThread : public Thread { queue.Wait(); } + public: /** Notifies parent by making the SignalFD ready to read * No requirements on locking */ void NotifyParent(); - public: - SocketThread(InspIRCd* SI); + SocketThread(); virtual ~SocketThread(); /** Lock queue. */