diff options
author | Travis CI <zmoelnig@travis-ci.umlaeute.mur.at> | 2015-03-17 22:38:45 +0000 |
---|---|---|
committer | Travis CI <zmoelnig@travis-ci.umlaeute.mur.at> | 2015-03-17 22:38:45 +0000 |
commit | 356f94fc355f36c16e48555d10c2377dff4b7554 (patch) | |
tree | 4b825dc642cb6eb9a060e54bf8d69288fbee4904 /Gem/develop/include/Gem/Utils/WorkerThread.h | |
parent | 5c694f159b012d1d94bf15bfe580dec52e4fe797 (diff) |
Gem 096ed6ef786b7a9d6e11a437ff8526619c89a1fd osx/x86_64
built 'coverity_scan:096ed6ef786b7a9d6e11a437ff8526619c89a1fd' for osx/x86_64
Diffstat (limited to 'Gem/develop/include/Gem/Utils/WorkerThread.h')
-rw-r--r-- | Gem/develop/include/Gem/Utils/WorkerThread.h | 81 |
1 files changed, 0 insertions, 81 deletions
diff --git a/Gem/develop/include/Gem/Utils/WorkerThread.h b/Gem/develop/include/Gem/Utils/WorkerThread.h deleted file mode 100644 index 9ab2285..0000000 --- a/Gem/develop/include/Gem/Utils/WorkerThread.h +++ /dev/null @@ -1,81 +0,0 @@ -/*----------------------------------------------------------------- -LOG - GEM - Graphics Environment for Multimedia - - WorkerThread.h - - part of GEM - - baseclass for queueing/dequeueing workloads for threaded - - Copyright (c) 2011-2011 IOhannes m zmölnig. forum::für::umläute. IEM. zmoelnig@iem.at - For information on usage and redistribution, and for a DISCLAIMER OF ALL - WARRANTIES, see the file, "GEM.LICENSE.TERMS" in this distribution. - ------------------------------------------------------------------*/ - -#ifndef _INCLUDE__GEM_GEM_WORKERTHREAD_H_ -#define _INCLUDE__GEM_GEM_WORKERTHREAD_H_ - -#include "Gem/ExportDef.h" - -namespace gem { namespace thread { - class GEM_EXTERN WorkerThread { - private: - class PIMPL; - PIMPL*m_pimpl; - friend class PIMPL; - /* dummy implementations */ - WorkerThread(const WorkerThread&); - WorkerThread&operator=(const WorkerThread&); - public: - WorkerThread(void); - virtual ~WorkerThread(void); - - //// - // start/stop thread(s) - virtual bool start(void); - virtual bool stop(bool wait=true); - - typedef unsigned int id_t; - static const id_t INVALID; - static const id_t IMMEDIATE; - - // queue a 'data' chunk onto the TODO queue - // the returned 'ID' can be used to interact with the queues - // if queuing failed, FALSE is returned and ID is set to INVALID - virtual bool queue(id_t&ID, void*data); - - ////// - // cancel a datachunk from the TODO-queue - // if the chunk was successfully removed, returns TRUE - // (FALSE is returned, if e.g. the given datachunk was not found in the queue) - // note that items already processed cannot be cancelled anymore - virtual bool cancel(const id_t ID); - - // dequeue the next datachunk from the DONE queue - // if the queue is empty, FALSE is returned and ID is set to INVALID - virtual bool dequeue(id_t&ID, void*&data); - - protected: - - //// - // the worker! - // get's called from an alternative thread(s) - // when the queue is non-empty, - // the first element is removed from the TODO queue, - // and this function is called with the 1st element as data - // the result returned is added to the done queue (alongside the ID) - virtual void* process(id_t ID, void*data) = 0; - - //// - // this get's called to indicate that new data is in the DONE queue - // you can use it to set a semaphore in the main thread, to fetch - // the data - // it get's called once after process() has been successful - // and will nott be called before dequeue has been called at least once - // - virtual void signal(void); - - };};}; - - -#endif /* _INCLUDE__GEM_GEM_WORKERTHREAD_H_ */ |