ichthyo/LUMIERA.clone
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Thread-wrapper: improve comments, push action down into private function

Browse source
This commit is contained in:
Fischlurch 2009-01-18 15:18:58 +01:00
parent 63565ebd97
commit 2679156a9c
1 changed files with 25 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

30
src/backend/thread-wrapper.hpp
View file

@ -42,8 +42,10 @@ namespace lib {
using std::tr1::function;
using lumiera::Literal;
typedef struct nobug_flag* NoBugFlag;
/**
/****************************************************************************
* A thin convenience wrapper for dealing with threads,
* as implemented by the backend (on top of pthread).
* Using this wrapper...
@ -87,10 +89,8 @@ namespace lib {
}
public:
Thread (Literal& purpose, Operation const& operation, struct nobug_flag *logging_flag = &NOBUG_FLAG(operate))
: started_(false),
operation_(operation)
void
start_thread (Literal& purpose, NoBugFlag logging_flag)
{
Lock sync(this);
LumieraThread res =
@ -109,6 +109,26 @@ namespace lib {
// prior to leaving and thereby possibly destroying this local context
sync.wait (started_);
}
public:
/** Create a new thread to execute the given operation.
* The new thread starts up synchronously, i.e. when the ctor returns, the new thread
* has started running and taken over (copied) the operation functor passed in. The
* thread will be created by lumiera_thread_run (declared in threads.h), it can't
* be cancelled and it can't be joined.
* @param purpose fixed char string used to denote the thread for diagnostics
* @param logging_flag NoBug flag to receive diagnostics regarding the new thread
* @param operation defining what to execute within the new thread. Any functor
* which can be bound to function<void(void)>. Note this functor will be
* copied onto the stack of the new thread, thus it can be transient.
*
*/
Thread (Literal& purpose, Operation const& operation, NoBugFlag logging_flag = &NOBUG_FLAG(operate)) ///TODO: define a dedicated flag for threads
: started_(false),
operation_(operation)
{
start_thread (purpose, logging_flag);
}
};