dep/src/zthread/SynchronousExecutor.cxx

   1 /*
   2  * Copyright (c) 2005, Eric Crahen
   3  *
   4  * Permission is hereby granted, free of charge, to any person obtaining a copy
   5  * of this software and associated documentation files (the "Software"), to deal
   6  * in the Software without restriction, including without limitation the rights
   7  * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
   8  * copies of the Software, and to permit persons to whom the Software is furnished
   9  * to do so, subject to the following conditions:
  10  *
  11  * The above copyright notice and this permission notice shall be included in all
  12  * copies or substantial portions of the Software.
  13  *
  14  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
  15  * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
  16  * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
  17  * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY,
  18  * WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
  19  * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
  20  *
  21  */
  22
  23 #include "zthread/SynchronousExecutor.h"
  24
  25 namespace ZThread {
  26
  27   SynchronousExecutor::SynchronousExecutor()
  28     : _canceled(false) {}
  29
  30   SynchronousExecutor::~SynchronousExecutor() {
  31   }
  32
  33   void SynchronousExecutor::cancel() {
  34
  35     Guard<Mutex> g(_lock);
  36     _canceled = true;
  37
  38   }
  39
  40   bool SynchronousExecutor::isCanceled() {
  41
  42     Guard<Mutex> g(_lock);
  43     return _canceled;
  44
  45   }
  46
  47   void SynchronousExecutor::interrupt() {
  48   }
  49
  50   void SynchronousExecutor::execute(const Task& task) {
  51
  52     // Canceled Executors will not accept new tasks, quick
  53     // check to avoid excessive locking in the canceled state
  54     if(_canceled)
  55       throw Cancellation_Exception();
  56
  57     Guard<Mutex> g(_lock);
  58
  59     if(_canceled) // Double check
  60       throw Cancellation_Exception();
  61
  62     // Run the task.
  63     Task(task)->run();
  64
  65   }
  66
  67   void SynchronousExecutor::wait() {
  68
  69     if(Thread::interrupted())
  70       throw Interrupted_Exception();
  71
  72     Guard<Mutex> g(_lock);
  73
  74   }
  75
  76   /**
  77    * @see Executor::wait(unsigned long)
  78    */
  79   bool SynchronousExecutor::wait(unsigned long) {
  80
  81     if(Thread::interrupted())
  82       throw Interrupted_Exception();
  83
  84     Guard<Mutex> g(_lock);
  85     return true;
  86
  87   }
  88
  89
  90 }