XrdCl::SyncQueue< Item > Class Template Reference

A synchronized queue. More...

#include <XrdClSyncQueue.hh>

Collaboration diagram for XrdCl::SyncQueue< Item >:

Public Member Functions
	SyncQueue ()
	Constructor.
	~SyncQueue ()
	Destructor.
void	Clear ()
	Clear the queue.
Item	Get ()
	Get the item from the front of the queue.
bool	IsEmpty ()
	Check if the queue is empty.
void	Put (const Item &item)
	Put the item in the queue.

Protected Attributes
XrdSysMutex	pMutex
std::queue< Item >	pQueue
XrdSysSemaphore *	pSem

Detailed Description

template<typename Item>
class XrdCl::SyncQueue< Item >

A synchronized queue.

Definition at line 32 of file XrdClSyncQueue.hh.

Constructor & Destructor Documentation

SyncQueue()

template<typename Item >

XrdCl::SyncQueue< Item >::SyncQueue ( )

inline

Constructor.

Definition at line 38 of file XrdClSyncQueue.hh.

      {
        pSem = new XrdSysSemaphore(0);
      };

References XrdCl::SyncQueue< Item >::pSem.

~SyncQueue()

template<typename Item >

XrdCl::SyncQueue< Item >::~SyncQueue ( )

inline

Destructor.

Definition at line 46 of file XrdClSyncQueue.hh.

      {
        delete pSem;
      }

References XrdCl::SyncQueue< Item >::pSem.

Member Function Documentation

Clear()

template<typename Item >

void XrdCl::SyncQueue< Item >::Clear ( )

inline

Clear the queue.

Definition at line 81 of file XrdClSyncQueue.hh.

      {
        XrdSysMutexHelper scopedLock( pMutex );
        while( !pQueue.empty() )
          pQueue.pop();
        delete pSem;
        pSem = new XrdSysSemaphore(0);
      }

References XrdCl::SyncQueue< Item >::pMutex, XrdCl::SyncQueue< Item >::pQueue, and XrdCl::SyncQueue< Item >::pSem.

Referenced by XrdCl::JobManager::Finalize().

Here is the caller graph for this function:

Get()

template<typename Item >

Item XrdCl::SyncQueue< Item >::Get ( )

inline

Get the item from the front of the queue.

Definition at line 64 of file XrdClSyncQueue.hh.

      {
        pSem->Wait();
        XrdSysMutexHelper scopedLock( pMutex );
 
        // this is not possible, so when it happens we commit a suicide
        if( pQueue.empty() )
          abort();
 
        Item i = pQueue.front();
        pQueue.pop();
        return i;
      }

References XrdCl::SyncQueue< Item >::pMutex, XrdCl::SyncQueue< Item >::pQueue, XrdCl::SyncQueue< Item >::pSem, and XrdSysSemaphore::Wait().

Referenced by XrdCl::JobManager::RunJobs().

Here is the call graph for this function:

Here is the caller graph for this function:

IsEmpty()

template<typename Item >

bool XrdCl::SyncQueue< Item >::IsEmpty ( )

inline

Check if the queue is empty.

Definition at line 93 of file XrdClSyncQueue.hh.

      {
        XrdSysMutexHelper scopedLock( pMutex );
        return pQueue.empty();
      }

References XrdCl::SyncQueue< Item >::pMutex, and XrdCl::SyncQueue< Item >::pQueue.

Put()

template<typename Item >

void XrdCl::SyncQueue< Item >::Put ( const Item &  item )

inline

Put the item in the queue.

Definition at line 54 of file XrdClSyncQueue.hh.

      {
        XrdSysMutexHelper scopedLock( pMutex );
        pQueue.push( item );
        pSem->Post();
      }

References XrdCl::SyncQueue< Item >::pMutex, XrdSysSemaphore::Post(), XrdCl::SyncQueue< Item >::pQueue, and XrdCl::SyncQueue< Item >::pSem.

Referenced by XrdCl::JobManager::QueueJob().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

pMutex

template<typename Item >

XrdSysMutex XrdCl::SyncQueue< Item >::pMutex

protected

Definition at line 101 of file XrdClSyncQueue.hh.

Referenced by XrdCl::SyncQueue< Item >::Clear(), XrdCl::SyncQueue< Item >::Get(), XrdCl::SyncQueue< Item >::IsEmpty(), and XrdCl::SyncQueue< Item >::Put().

pQueue

template<typename Item >

std::queue<Item> XrdCl::SyncQueue< Item >::pQueue

protected

Definition at line 100 of file XrdClSyncQueue.hh.

Referenced by XrdCl::SyncQueue< Item >::Clear(), XrdCl::SyncQueue< Item >::Get(), XrdCl::SyncQueue< Item >::IsEmpty(), and XrdCl::SyncQueue< Item >::Put().

pSem

template<typename Item >

XrdSysSemaphore* XrdCl::SyncQueue< Item >::pSem

protected

Definition at line 102 of file XrdClSyncQueue.hh.

Referenced by XrdCl::SyncQueue< Item >::SyncQueue(), XrdCl::SyncQueue< Item >::~SyncQueue(), XrdCl::SyncQueue< Item >::Clear(), XrdCl::SyncQueue< Item >::Get(), and XrdCl::SyncQueue< Item >::Put().

---

The documentation for this class was generated from the following file:

• XrdClSyncQueue.hh