src/beacons/future_event.hpp

   1 /**
   2  * beacon
   3  * Author: Lukas Krejci <krejci.l@centrum.cz>, (C) 2008
   4  * Copyright: See COPYING file that comes with this distribution
   5  */
   6
   7 #ifndef BEACONS_FUTURE_EVENT_H
   8 #define BEACONS_FUTURE_EVENT_H
   9
  10 #include <beacons/future.hpp>
  11 #include <beacons/detail/future_event_base.hpp>
  12
  13 namespace beacons {
  14
  15 /**
  16  * An implementation of the future interface that cooperates with
  17  * {@link event_loop}.
  18  */
  19 template<typename ResultType>
  20 class future_event : public future<ResultType>, public detail::future_event_base {
  21     public:
  22
  23         future_event() : future_event_base() {
  24         }
  25
  26         /** currently always fails returning false */
  27         bool cancel() {
  28             return this->future_event_base::cancel();
  29         }
  30
  31         bool finished() const {
  32             return this->future_event_base::finished();
  33         }
  34
  35         ResultType get() throw (execution_exception) {
  36             ResultType * ret = static_cast<ResultType *>(this->future_event_base::get());
  37
  38             return *ret;
  39         }
  40
  41         ResultType get(int timeout) throw(execution_exception, timeout_exception) {
  42             ResultType * ret = static_cast<ResultType *>(this->future_event_base::get(timeout));
  43
  44             return *ret;
  45         }
  46 };
  47
  48 template<>
  49 class future_event<void> : public future<void>, public detail::future_event_base {
  50     public:
  51
  52         future_event() : future_event_base() {
  53         }
  54
  55         /** currently always fails returning false */
  56         bool cancel() {
  57             return this->future_event_base::cancel();
  58         }
  59
  60         bool finished() const {
  61             return this->future_event_base::finished();
  62         }
  63
  64         void get() throw (execution_exception) {
  65             this->future_event_base::get();
  66         }
  67
  68         void get(int timeout) throw(execution_exception, timeout_exception) {
  69             this->future_event_base::get();
  70         }
  71 };
  72
  73 }
  74
  75 #endif