Jobqueue - one per process. More...

#include <tnt/job.h>

Public Types

typedef cxxtools::SmartPtr< JobJobPtr

Public Member Functions

 Jobqueue (unsigned capacity_=1000)
void put (JobPtr &j, bool force=false)
JobPtr get ()
void setCapacity (unsigned c)
unsigned getCapacity () const
unsigned getWaitThreadCount () const
bool empty () const

Public Attributes

cxxtools::Condition noWaitThreads

Detailed Description

Jobqueue - one per process.

Member Typedef Documentation

Constructor & Destructor Documentation

tnt::Jobqueue::Jobqueue ( unsigned  capacity_ = 1000)
inlineexplicit

Member Function Documentation

bool tnt::Jobqueue::empty ( ) const
inline
JobPtr tnt::Jobqueue::get ( )
unsigned tnt::Jobqueue::getCapacity ( ) const
inline
unsigned tnt::Jobqueue::getWaitThreadCount ( ) const
inline
void tnt::Jobqueue::put ( JobPtr j,
bool  force = false 
)
void tnt::Jobqueue::setCapacity ( unsigned  c)
inline

Member Data Documentation

cxxtools::Condition tnt::Jobqueue::noWaitThreads

The documentation for this class was generated from the following file:
  • framework/common/tnt/job.h