thread_win.hpp
Go to the documentation of this file.
1 
8 /*****************************************************************************
9 ** Ifdefs
10 *****************************************************************************/
11 
12 #ifndef ECL_THREADS_THREAD_WIN_HPP_
13 #define ECL_THREADS_THREAD_WIN_HPP_
14 
15 /*****************************************************************************
16 ** Platform Check
17 *****************************************************************************/
18 
19 #include <ecl/config/ecl.hpp>
20 #if defined(ECL_IS_WIN32)
21 
22 /*****************************************************************************
23 ** Includes
24 *****************************************************************************/
25 
26 #include <windows.h>
27 #include "thread_exceptions_pos.hpp"
28 #include <ecl/config/macros.hpp>
29 #include <ecl/concepts/nullary_function.hpp>
30 #include <ecl/exceptions/standard_exception.hpp>
31 #include <ecl/utilities/void.hpp>
32 #include <ecl/utilities/function_objects.hpp>
33 #include "priority_win.hpp"
34 
35 /*****************************************************************************
36 ** Namespaces
37 *****************************************************************************/
38 
39 namespace ecl {
40 namespace threads {
41 
42 /*****************************************************************************
43 ** Interface [ThreadTask]
44 *****************************************************************************/
51 class ECL_LOCAL ThreadTaskBase {
52 public:
53  virtual ~ThreadTaskBase() {};
54 
55 protected:
56  ThreadTaskBase(const Priority& priority) : priority_level(priority) {};
57  ecl::Priority priority_level;
58 };
68 template <typename F, bool IsReferenceWrapper = false>
69 class ECL_LOCAL ThreadTask : public ThreadTaskBase {
70 public:
79  ThreadTask(const F &f, const Priority &priority) : ThreadTaskBase(priority), function(f) {
81  };
82  virtual ~ThreadTask() {};
94  static unsigned int EntryPoint(void *ptr_this) {
95  ThreadTask< F, false > *ptr = static_cast< ThreadTask< F, false > * >(ptr_this);
96  (ptr->function)();
97  return 0;
98  }
99 
100 private:
101  F function;
102 };
103 
113 template <typename F>
114 class ECL_LOCAL ThreadTask<F, true> : public ThreadTaskBase {
115 public:
124  ThreadTask(const F &f, const Priority &priority) : ThreadTaskBase(priority), function(f.reference()) {
126  };
127  virtual ~ThreadTask() {};
138  static unsigned int EntryPoint(void *ptr_this) {
139  ThreadTask< F, true > *ptr = static_cast< ThreadTask< F, true > * >(ptr_this);
140  (ptr->function)();
141  return 0;
142  }
143 
144 private:
145  typename F::type &function;
146 };
147 
148 }; // namespace threads
149 
150 /*****************************************************************************
151 ** Interface [Thread]
152 *****************************************************************************/
226 class ecl_threads_PUBLIC Thread {
227 public:
235  Thread() :
236  thread_handle(NULL),
237  thread_task(NULL),
238  has_started(false),
239  join_requested(false)
240  {}
260  Thread(VoidFunction function, const Priority &priority = DefaultPriority, const long &stack_size = -1 ) ecl_debug_throw_decl(StandardException);
270  Error start(VoidFunction function, const Priority &priority = DefaultPriority, const long &stack_size = -1 ) ecl_debug_throw_decl(StandardException);
294  template <typename C>
295  Thread(void (C::*function)(), C &c, const Priority &priority = DefaultPriority, const long &stack_size = -1 ) ecl_debug_throw_decl(StandardException);
306  template <typename C>
307  Error start(void (C::*function)(), C &c, const Priority &priority = DefaultPriority, const long &stack_size = -1 ) ecl_debug_throw_decl(StandardException);
308 
347  template <typename F>
348  Thread(const F &function, const Priority &priority = DefaultPriority, const long &stack_size = -1 ) ecl_debug_throw_decl(StandardException);
358  template <typename F>
359  Error start(const F &function, const Priority &priority = DefaultPriority, const long &stack_size = -1 ) ecl_debug_throw_decl(StandardException);
360 
369  virtual ~Thread();
370 
376  bool isRunning() { if ( thread_task == NULL ) { return false; } else { return true; } }
377 
391  void cancel() ecl_debug_throw_decl(StandardException);
392 
400  void join() ecl_assert_throw_decl(StandardException);
401 
402 
403 private:
404  HANDLE thread_handle;
405  threads::ThreadTaskBase *thread_task;
406  bool has_started;
407  bool join_requested;
408 
409  void initialise(const long &stack_size) ecl_assert_throw_decl(StandardException);
410 
411  enum ThreadProperties {
412  DefaultStackSize = -1
413  };
414 };
415 
416 /*****************************************************************************
417 ** Template Implementation [Thread]
418 *****************************************************************************/
419 
420 template <typename C>
421 Thread::Thread(void (C::*function)(), C &c, const Priority &priority, const long &stack_size) ecl_debug_throw_decl(StandardException) :
422  thread_handle(NULL),
423  thread_task(NULL),
424  has_started(false),
425  join_requested(false)
426 {
427  start<C>(function, c, priority, stack_size);
428 
429 }
430 
431 template <typename F>
432 Thread::Thread(const F &function, const Priority &priority, const long &stack_size) ecl_debug_throw_decl(StandardException) :
433  thread_handle(NULL),
434  thread_task(NULL),
435  has_started(false),
436  join_requested(false)
437 {
438  start<F>(function, priority, stack_size);
439 }
440 
441 template <typename C>
442 Error Thread::start(void (C::*function)(), C &c, const Priority &priority, const long &stack_size) ecl_debug_throw_decl(StandardException)
443 {
444  // stack_size is ignored
445 
446  if ( has_started ) {
447  ecl_debug_throw(StandardException(LOC,BusyError,"The thread has already been started."));
448  return Error(BusyError); // if in release mode, gracefully fall back to return values.
449  } else {
450  has_started = true;
451  }
452 
453  thread_task = new threads::ThreadTask< BoundNullaryMemberFunction<C,void> >(generateFunctionObject( function, c ), priority);
454 
455  DWORD threadid;
456 
457  thread_handle = CreateThread(NULL,
458  0,
459  (LPTHREAD_START_ROUTINE)threads::ThreadTask< BoundNullaryMemberFunction<C,void> >::EntryPoint,
460  thread_task,
461  0,
462  &threadid);
463 
464  if (!thread_handle) {
465  ecl_debug_throw(StandardException(LOC, UnknownError, "Failed to create thread."));
466  return Error(UnknownError);
467  }
468 
469  BOOL bResult = FALSE;
470 
471  if (priority >= RealTimePriority1) {
472  bResult = SetThreadPriority(thread_handle, THREAD_PRIORITY_TIME_CRITICAL);
473  }
474 
475  switch (priority) {
476  case CriticalPriority:
477  bResult = SetThreadPriority(thread_handle, HIGH_PRIORITY_CLASS);
478  break;
479  case HighPriority:
480  bResult = SetThreadPriority(thread_handle, THREAD_PRIORITY_ABOVE_NORMAL);
481  break;
482  case LowPriority:
483  bResult = SetThreadPriority(thread_handle, THREAD_PRIORITY_BELOW_NORMAL);
484  break;
485  case BackgroundPriority:
486  bResult = SetThreadPriority(thread_handle, THREAD_PRIORITY_IDLE);
487  break;
488  default:
489  break;
490  }
491 
492  if (!bResult) {
493  ecl_debug_throw(threads::throwPriorityException(LOC));
494  }
495 
496  return Error(NoError);
497 }
498 
499 template <typename F>
500 Error Thread::start(const F &function, const Priority &priority, const long &stack_size) ecl_debug_throw_decl(StandardException)
501 {
502  // stack_size is ignored
503 
504  if ( has_started ) {
505  ecl_debug_throw(StandardException(LOC,BusyError,"The thread has already been started."));
506  return Error(BusyError); // if in release mode, gracefully fall back to return values.
507  } else {
508  has_started = true;
509  }
510 
511  thread_task = new threads::ThreadTask<F, is_reference_wrapper<F>::value >(function, priority);
512 
513  DWORD threadid;
514 
515  thread_handle = CreateThread(NULL,
516  0,
517  (LPTHREAD_START_ROUTINE)threads::ThreadTask<F, is_reference_wrapper<F>::value >::EntryPoint,
518  thread_task,
519  0,
520  &threadid);
521 
522  if (!thread_handle) {
523  ecl_debug_throw(StandardException(LOC, UnknownError, "Failed to create thread."));
524  return Error(UnknownError);
525  }
526 
527  BOOL bResult = FALSE;
528 
529  if (priority >= RealTimePriority1) {
530  bResult = SetThreadPriority(thread_handle, THREAD_PRIORITY_TIME_CRITICAL);
531  }
532 
533  switch (priority) {
534  case CriticalPriority:
535  bResult = SetThreadPriority(thread_handle, HIGH_PRIORITY_CLASS);
536  break;
537  case HighPriority:
538  bResult = SetThreadPriority(thread_handle, THREAD_PRIORITY_ABOVE_NORMAL);
539  break;
540  case LowPriority:
541  bResult = SetThreadPriority(thread_handle, THREAD_PRIORITY_BELOW_NORMAL);
542  break;
543  case BackgroundPriority:
544  bResult = SetThreadPriority(thread_handle, THREAD_PRIORITY_IDLE);
545  break;
546  default:
547  break;
548  }
549 
550  if (!bResult) {
551  ecl_debug_throw(threads::throwPriorityException(LOC));
552  }
553 
554  return Error(NoError);
555 }
556 
557 }; // namespace ecl
558 
559 #endif /* ECL_IS_WIN32 */
560 #endif /* ECL_THREADS_THREAD_WIN_HPP_ */
DefaultPriority
#define LOC
Stringify the line of code you are at.
CriticalPriority
BackgroundPriority
UnknownError
RealTimePriority1
void(* VoidFunction)()
Error
#define ECL_LOCAL
BoundUnaryFreeFunction< A, R > generateFunctionObject(R(*function)(A), I &a)
Generate a nullary function object from a bound unary global/static function.
static bool const value
The value for this integral constant wrapper.
Definition: bool.hpp:34
#define ecl_threads_PUBLIC
#define ecl_assert_throw_decl(exception)
Assure throw exception declaration.
HighPriority
#define ecl_compile_time_concept_check(Model)
Compile time concept checking assertion.
LowPriority
#define ecl_debug_throw_decl(exception)
Debug mode throw exception declaration.
#define ecl_debug_throw(exception)
Debug mode exception throw.
Virtual interface definition for nullary function objects.
Priority


xbot_node
Author(s): Roc, wangpeng@droid.ac.cn
autogenerated on Sat Oct 10 2020 03:28:13