trequest.hpp

Go to the documentation of this file.

/** ************************************************************************************************
 * \file
 * This header file is part of module \alib_threads of the \aliblong.
 *
 * \emoji :copyright: 2013-2019 A-Worx GmbH, Germany.
 * Published under \ref mainpage_license "Boost Software License".
 **************************************************************************************************/
#ifndef HPP_AWORX_ALIB_THREADS_MODEL_TREQUEST
#define HPP_AWORX_ALIB_THREADS_MODEL_TREQUEST
 
 
#if !defined(ALIB_DOX)  // todo remove
 
 
#if !defined (HPP_ALIB_THREADS_THREADLOCK)
#   include "alib/threads/threadlock.hpp"
#endif
 
 
#include <semaphore.h>
 
namespace alib { namespace threads::model {
 
/** ************************************************************************************************
 * TODOX
 * TODO(240316 08:42):
 *   We should have a dedicated allocator for all thread things.
 *   Then, a hashtable should use RTTI to recycle TRequest objects. Thus, those objects are
 *   always created using the ThreadManager interface (or wherever this goes) and likewise
 *   destroyed. When destroyed, they are added to the type-dependend recycling list found in
 *   the hashtable.
 *   Or: rather use "sizeof" instead of RTTI!
 **************************************************************************************************/
class TRequest
{
  public:     // todo: use std::future with a std::promise
                 TRequest(void* data= nullptr);
    virtual ~TRequest();
    bool isProcessed();
    bool waitUntilProcessed(int millisecs= -1);
    void setProcessed();
 
public:
    int                 status;
    void*               data;
    void*               data2;
 
    sem_t               event;    // with Posix we implement it with a real semaphore
    alib::ThreadLock    lock;     // sync the semaphore access
};
 
} // namespace alib[::threads::model]
 
/// Type alias in namespace #aworx.
using      TRequest         = alib::threads::model::TRequest;
 
 
}  // namespace [alib]
 
 
#endif // !defined(ALIB_DOX)
 
#endif // HPP_AWORX_ALIB_THREADS_MODEL_TREQUEST