LibThread::SingularChannel Class Reference

Public Member Functions
	SingularChannel ()
virtual	~SingularChannel ()
void	send (string item)
string	receive ()
long	count ()
Public Member Functions inherited from LibThread::SharedObject
	SharedObject ()
virtual	~SharedObject ()
void	set_type (int type_init)
int	get_type ()
void	set_name (std::string &name_init)
void	set_name (const char *s)
std::string &	get_name ()
void	incref (int by=1)
long	decref ()
long	getref ()
virtual BOOLEAN	op2 (int op, leftv res, leftv a1, leftv a2)
virtual BOOLEAN	op3 (int op, leftv res, leftv a1, leftv a2, leftv a3)

Private Attributes
queue< string >	q
Lock	lock
ConditionVariable	cond

Detailed Description

Definition at line 397 of file shared.cc.

Constructor & Destructor Documentation

SingularChannel()

LibThread::SingularChannel::SingularChannel ( )

inline

Definition at line 403 of file shared.cc.

: SharedObject(), lock(), cond(&lock) { }

~SingularChannel()

virtual LibThread::SingularChannel::~SingularChannel ( )

inlinevirtual

Definition at line 404 of file shared.cc.

{ }

Member Function Documentation

count()

long LibThread::SingularChannel::count ( )

inline

Definition at line 423 of file shared.cc.

               {
    lock.lock();
    long result = q.size();
    lock.unlock();
    return result;
  }

receive()

string LibThread::SingularChannel::receive ( )

inline

Definition at line 411 of file shared.cc.

                   {
    lock.lock();
    while (q.empty()) {
      cond.wait();
    }
    string result = q.front();
    q.pop();
    if (!q.empty())
      cond.signal();
    lock.unlock();
    return result;
  }

send()

void LibThread::SingularChannel::send ( string  item )

inline

Definition at line 405 of file shared.cc.

                         {
    lock.lock();
    q.push(item);
    cond.signal();
    lock.unlock();
  }

Field Documentation

cond

ConditionVariable LibThread::SingularChannel::cond

private

Definition at line 401 of file shared.cc.

lock

Lock LibThread::SingularChannel::lock

private

Definition at line 400 of file shared.cc.

q

queue<string> LibThread::SingularChannel::q

private

Definition at line 399 of file shared.cc.

---

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

• Singular/dyn_modules/systhreads/shared.cc