24 #ifndef _IGNITE_FUTURE
25 #define _IGNITE_FUTURE
27 #include <ignite/common/shared_state.h>
84 const common::SharedState<ValueType>* state0 = state.Get();
100 const common::SharedState<ValueType>* state0 = state.Get();
104 return state0->WaitFor(msTimeout);
116 const common::SharedState<ValueType>* state0 = state.Get();
120 return state0->GetValue();
128 common::SharedState<ValueType>* state0 = state.Get();
140 common::SharedState<ValueType>* state0 = state.Get();
144 return state0->IsSet();
153 Future(common::concurrent::SharedPointer< common::SharedState<ValueType> > state0) :
160 common::concurrent::SharedPointer< common::SharedState<ValueType> > state;
205 const common::SharedState<ValueType>* state0 = state.Get();
221 const common::SharedState<ValueType>* state0 = state.Get();
225 return state0->WaitFor(msTimeout);
236 const common::SharedState<ValueType>* state0 = state.Get();
248 common::SharedState<ValueType>* state0 = state.Get();
260 common::SharedState<ValueType>* state0 = state.Get();
264 return state0->IsSet();
273 Future(common::concurrent::SharedPointer< common::SharedState<ValueType> > state0) :
280 common::concurrent::SharedPointer< common::SharedState<ValueType> > state;
287 class Future< common::concurrent::SharedPointer<T> >
303 Future(const Future<SP_ValueType>& src) :
329 const common::SharedState<SP_ValueType>* state0 = state.Get();
345 const common::SharedState<SP_ValueType>* state0 = state.Get();
349 return state0->WaitFor(msTimeout);
361 const common::SharedState<SP_ValueType>* state0 = state.Get();
365 return state0->GetValue();
373 common::SharedState<SP_ValueType>* state0 = state.Get();
385 common::SharedState<SP_ValueType>* state0 = state.Get();
389 return state0->IsSet();
398 Future(common::concurrent::SharedPointer< common::SharedState<SP_ValueType> > state0) :
405 common::concurrent::SharedPointer< common::SharedState<SP_ValueType> > state;
409 #endif //_IGNITE_FUTURE