diff options
Diffstat (limited to 'attic/muse2-oom/muse2/muse/thread.h')
-rw-r--r-- | attic/muse2-oom/muse2/muse/thread.h | 104 |
1 files changed, 104 insertions, 0 deletions
diff --git a/attic/muse2-oom/muse2/muse/thread.h b/attic/muse2-oom/muse2/muse/thread.h new file mode 100644 index 00000000..f9642301 --- /dev/null +++ b/attic/muse2-oom/muse2/muse/thread.h @@ -0,0 +1,104 @@ +//========================================================= +// MusE +// Linux Music Editor +// $Id: thread.h,v 1.1.1.1.2.2 2009/12/20 05:00:35 terminator356 Exp $ +// +// (C) Copyright 2001 Werner Schweer (ws@seh.de) +//========================================================= + +#ifndef __THREAD_H__ +#define __THREAD_H__ + +#include <pthread.h> +#include <list> + +//--------------------------------------------------------- +// Poll +//--------------------------------------------------------- + +struct Poll { + int fd; + int action; + void (*handler)(void*,void*); + void* param1; + void* param2; + + Poll(int _fd, int _action, void(*_handler)(void*,void*), void* p, void* q) { + fd = _fd; + action = _action; + handler = _handler; + param1 = p; + param2 = q; + } + }; + +typedef std::list<Poll> PollList; +typedef std::list<Poll>::iterator iPoll; + + +//--------------------------------------------------------- +// ThreadMsg +//--------------------------------------------------------- + +struct ThreadMsg { + int id; + }; + +//--------------------------------------------------------- +// Thread +//--------------------------------------------------------- + +class Thread { + const char* _name; + volatile bool _running; + //int realTimePriority; + int _pollWait; // poll timeout in msec (-1 = infinite) + + pthread_t thread; + + int toThreadFdw; // message to thread (app write) + + PollList plist; +// pthread_mutex_t lock; +// pthread_cond_t ready; + void* userPtr; + + protected: + int _realTimePriority; + int fromThreadFdr; // message from thread (seq read) + int fromThreadFdw; // message from thread (app write) + int toThreadFdr; // message to thread (seq read) + struct pollfd* pfd; // poll file descriptors + int npfd; + int maxpfd; + virtual void processMsg(const ThreadMsg*) {} + virtual void processMsg1(const void *) {} + virtual void defaultTick() {} + + public: + //Thread(int prio, const char* name); + Thread(const char* name); + + virtual ~Thread(); + const char* name() const { return _name; } + + //virtual void start(void* ptr=0); + virtual void start(int priority, void* ptr=0); + + void stop(bool); + void clearPollFd() { plist.clear(); npfd = 0; } + void addPollFd(int fd, int action, void (*handler)(void*,void*), void*, void*); + void removePollFd(int fd, int action); + void loop(); + void readMsg(); + void readMsg1(int size); + bool sendMsg1(const void* m, int n); + bool sendMsg(const ThreadMsg* m); + bool isRunning() const { return _running; } + void setPollWait(int val) { _pollWait = val; } + virtual void threadStart(void*){ } // called from loop + virtual void threadStop() { } // called from loop before leaving + }; + +#endif + |