PFuture.h

 
#ifndef MFRAME_1C1490D6_E331_4C8B_A1CC_49D7A5549037
#define MFRAME_1C1490D6_E331_4C8B_A1CC_49D7A5549037
 
/* ***************************************************************************************
 * Include
 */
 
//----------------------------------------------------------------------------------------
 
//----------------------------------------------------------------------------------------
#include "./../lang/Object.h"
#include "./../sys/Thread.h"
#include "./../util/Future.h"
 
/* ***************************************************************************************
 * Namespace
 */
namespace ufm::util {
  class PFuture;
}  // namespace ufm::util
 
namespace ufm::io {
  struct OutputStream;
}  // namespace ufm::io
 
namespace ufm::lang {
  struct Readable;
}  // namespace ufm::lang
 
/* ***************************************************************************************
 * Class/Interface/Struct/Enum
 */
 
class ufm::util::PFuture : public ufm::lang::Object, public ufm::util::Future<int> {
  /* *************************************************************************************
   * Variable
   */
 private:
  int                     vResult;  
  ufm::util::FutureStatus vStatus;  
  ufm::sys::Thread*       vThread;  
 
  /* *************************************************************************************
   * Abstract Method
   */
 
  /* *************************************************************************************
   * Construct Method
   */
 public:
  PFuture(void);
 
  virtual ~PFuture(void) override;
 
  /* *************************************************************************************
   * Operator Method
   */
 public:
  template <typename E>
  inline operator const Future<E>&(void) const {
    const Future<>* src = this;
    return *reinterpret_cast<const Future<E>*>(src);
  }
 
  template <typename E>
  inline operator Future<E>&(void) {
    Future<>* src = this;
    return *reinterpret_cast<Future<E>*>(src);
  }
 
  /* *************************************************************************************
   * Override Method - ufm::util::Future<>
   */
 public:
  virtual bool get(int& result, int timeout) override;
 
  virtual bool setWait(void) override;
 
  virtual bool waitDone(int timeout) override;
 
  virtual void clear(void) override;
 
  virtual ufm::util::FutureStatus getStatus(void) override;
 
  /* *************************************************************************************
   * Override Method - ufm::util::Future<>
   */
 public:
  virtual void completed(int& result, void* attachment) override;
 
  virtual void failed(void* attachment) override;
 
  /* *************************************************************************************
   * Public Method
   */
 public:
  bool isBusy(void) const;
 
  int syncWrite(ufm::io::OutputStream& outputStream, 
                ufm::lang::Readable& readable, 
                int timeoutMs = 5000);
 
  /* *************************************************************************************
   * Protected Method
   */
 protected:
  void setCompleted(void);
 
  void setFailed(void);
 
  /* *************************************************************************************
   * Private Method
   */
 
  /* *************************************************************************************
   * Static Variable
   */
 
  /* *************************************************************************************
   * Static Method
   */
};
 
/* ***************************************************************************************
 * End of file
 */
 
#endif /* MFRAME_1C1490D6_E331_4C8B_A1CC_49D7A5549037 */