activemq-cpp-3.4.0
|
The interface for all synchronizable objects (that is, objects that can be locked and unlocked). More...
#include <src/main/decaf/util/concurrent/Synchronizable.h>
Public Member Functions | |
virtual | ~Synchronizable () |
virtual void | lock ()=0 |
Locks the object. | |
virtual bool | tryLock ()=0 |
Attempts to Lock the object, if the lock is already held by another thread than this method returns false. | |
virtual void | unlock ()=0 |
Unlocks the object. | |
virtual void | wait ()=0 |
Waits on a signal from this object, which is generated by a call to Notify. | |
virtual void | wait (long long millisecs)=0 |
Waits on a signal from this object, which is generated by a call to Notify. | |
virtual void | wait (long long millisecs, int nanos)=0 |
Waits on a signal from this object, which is generated by a call to Notify. | |
virtual void | notify ()=0 |
Signals a waiter on this object that it can now wake up and continue. | |
virtual void | notifyAll ()=0 |
Signals the waiters on this object that it can now wake up and continue. |
The interface for all synchronizable objects (that is, objects that can be locked and unlocked).
virtual decaf::util::concurrent::Synchronizable::~Synchronizable | ( | ) | [inline, virtual] |
virtual void decaf::util::concurrent::Synchronizable::lock | ( | ) | [pure virtual] |
Locks the object.
RuntimeException | if an error occurs while locking the object. |
Implemented in activemq::core::FifoMessageDispatchChannel, activemq::core::SimplePriorityMessageDispatchChannel, decaf::internal::util::concurrent::SynchronizableImpl, decaf::io::InputStream, decaf::io::OutputStream, decaf::util::AbstractCollection< E >, decaf::util::concurrent::ConcurrentStlMap< K, V, COMPARATOR >, decaf::util::concurrent::CopyOnWriteArrayList< E >, decaf::util::concurrent::Mutex, decaf::util::StlMap< K, V, COMPARATOR >, decaf::util::StlQueue< T >, decaf::util::AbstractCollection< Pointer< Transport > >, decaf::util::AbstractCollection< Pointer< Synchronization > >, decaf::util::AbstractCollection< Resource * >, decaf::util::AbstractCollection< cms::MessageConsumer * >, decaf::util::AbstractCollection< CompositeTask * >, decaf::util::AbstractCollection< URI >, decaf::util::AbstractCollection< Pointer< MessageDispatch > >, decaf::util::AbstractCollection< Pointer< DestinationInfo > >, decaf::util::AbstractCollection< PrimitiveValueNode >, decaf::util::AbstractCollection< Pointer< Command > >, decaf::util::AbstractCollection< Pointer< BackupTransport > >, decaf::util::AbstractCollection< cms::MessageProducer * >, decaf::util::AbstractCollection< cms::Destination * >, decaf::util::AbstractCollection< cms::Session * >, decaf::util::AbstractCollection< cms::Connection * >, decaf::util::concurrent::ConcurrentStlMap< Pointer< MessageId >, Pointer< Message >, MessageId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< ConnectionId >, Pointer< ConnectionState >, ConnectionId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< ConsumerId >, Pointer< ConsumerState >, ConsumerId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< SessionId >, Pointer< SessionState >, SessionId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< LocalTransactionId >, Pointer< TransactionState >, LocalTransactionId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< ProducerId >, Pointer< ProducerState >, ProducerId::COMPARATOR >, decaf::util::concurrent::CopyOnWriteArrayList< ServiceListener * >, decaf::util::StlMap< cms::Session *, SessionResolver * >, decaf::util::StlMap< std::string, WireFormatFactory * >, decaf::util::StlMap< decaf::lang::Runnable *, decaf::util::TimerTask * >, decaf::util::StlMap< std::string, PrimitiveValueNode >, decaf::util::StlMap< std::string, cms::Queue * >, decaf::util::StlMap< std::string, CachedConsumer * >, decaf::util::StlMap< Pointer< commands::ConsumerId >, ActiveMQConsumer *, commands::ConsumerId::COMPARATOR >, decaf::util::StlMap< std::string, TransportFactory * >, decaf::util::StlMap< Pointer< ConsumerId >, Pointer< ConsumerInfo >, ConsumerId::COMPARATOR >, decaf::util::StlMap< int, Pointer< Command > >, decaf::util::StlMap< std::string, CachedProducer * >, and decaf::util::StlMap< std::string, cms::Topic * >.
virtual void decaf::util::concurrent::Synchronizable::notify | ( | ) | [pure virtual] |
Signals a waiter on this object that it can now wake up and continue.
Must have this object locked before calling.
IllegalMonitorStateException | - if the current thread is not the owner of the the Synchronizable Object. |
RuntimeException | if an error occurs while notifying one of the waiting threads. |
Implemented in activemq::core::FifoMessageDispatchChannel, activemq::core::SimplePriorityMessageDispatchChannel, decaf::internal::util::concurrent::SynchronizableImpl, decaf::io::InputStream, decaf::io::OutputStream, decaf::util::AbstractCollection< E >, decaf::util::concurrent::ConcurrentStlMap< K, V, COMPARATOR >, decaf::util::concurrent::CopyOnWriteArrayList< E >, decaf::util::concurrent::Mutex, decaf::util::StlMap< K, V, COMPARATOR >, decaf::util::StlQueue< T >, decaf::util::AbstractCollection< Pointer< Transport > >, decaf::util::AbstractCollection< Pointer< Synchronization > >, decaf::util::AbstractCollection< Resource * >, decaf::util::AbstractCollection< cms::MessageConsumer * >, decaf::util::AbstractCollection< CompositeTask * >, decaf::util::AbstractCollection< URI >, decaf::util::AbstractCollection< Pointer< MessageDispatch > >, decaf::util::AbstractCollection< Pointer< DestinationInfo > >, decaf::util::AbstractCollection< PrimitiveValueNode >, decaf::util::AbstractCollection< Pointer< Command > >, decaf::util::AbstractCollection< Pointer< BackupTransport > >, decaf::util::AbstractCollection< cms::MessageProducer * >, decaf::util::AbstractCollection< cms::Destination * >, decaf::util::AbstractCollection< cms::Session * >, decaf::util::AbstractCollection< cms::Connection * >, decaf::util::concurrent::ConcurrentStlMap< Pointer< MessageId >, Pointer< Message >, MessageId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< ConnectionId >, Pointer< ConnectionState >, ConnectionId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< ConsumerId >, Pointer< ConsumerState >, ConsumerId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< SessionId >, Pointer< SessionState >, SessionId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< LocalTransactionId >, Pointer< TransactionState >, LocalTransactionId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< ProducerId >, Pointer< ProducerState >, ProducerId::COMPARATOR >, decaf::util::concurrent::CopyOnWriteArrayList< ServiceListener * >, decaf::util::StlMap< cms::Session *, SessionResolver * >, decaf::util::StlMap< std::string, WireFormatFactory * >, decaf::util::StlMap< decaf::lang::Runnable *, decaf::util::TimerTask * >, decaf::util::StlMap< std::string, PrimitiveValueNode >, decaf::util::StlMap< std::string, cms::Queue * >, decaf::util::StlMap< std::string, CachedConsumer * >, decaf::util::StlMap< Pointer< commands::ConsumerId >, ActiveMQConsumer *, commands::ConsumerId::COMPARATOR >, decaf::util::StlMap< std::string, TransportFactory * >, decaf::util::StlMap< Pointer< ConsumerId >, Pointer< ConsumerInfo >, ConsumerId::COMPARATOR >, decaf::util::StlMap< int, Pointer< Command > >, decaf::util::StlMap< std::string, CachedProducer * >, and decaf::util::StlMap< std::string, cms::Topic * >.
virtual void decaf::util::concurrent::Synchronizable::notifyAll | ( | ) | [pure virtual] |
Signals the waiters on this object that it can now wake up and continue.
Must have this object locked before calling.
IllegalMonitorStateException | - if the current thread is not the owner of the the Synchronizable Object. |
RuntimeException | if an error occurs while notifying the waiting threads. |
Implemented in activemq::core::FifoMessageDispatchChannel, activemq::core::SimplePriorityMessageDispatchChannel, decaf::internal::util::concurrent::SynchronizableImpl, decaf::io::InputStream, decaf::io::OutputStream, decaf::util::AbstractCollection< E >, decaf::util::concurrent::ConcurrentStlMap< K, V, COMPARATOR >, decaf::util::concurrent::CopyOnWriteArrayList< E >, decaf::util::concurrent::Mutex, decaf::util::StlMap< K, V, COMPARATOR >, decaf::util::StlQueue< T >, decaf::util::AbstractCollection< Pointer< Transport > >, decaf::util::AbstractCollection< Pointer< Synchronization > >, decaf::util::AbstractCollection< Resource * >, decaf::util::AbstractCollection< cms::MessageConsumer * >, decaf::util::AbstractCollection< CompositeTask * >, decaf::util::AbstractCollection< URI >, decaf::util::AbstractCollection< Pointer< MessageDispatch > >, decaf::util::AbstractCollection< Pointer< DestinationInfo > >, decaf::util::AbstractCollection< PrimitiveValueNode >, decaf::util::AbstractCollection< Pointer< Command > >, decaf::util::AbstractCollection< Pointer< BackupTransport > >, decaf::util::AbstractCollection< cms::MessageProducer * >, decaf::util::AbstractCollection< cms::Destination * >, decaf::util::AbstractCollection< cms::Session * >, decaf::util::AbstractCollection< cms::Connection * >, decaf::util::concurrent::ConcurrentStlMap< Pointer< MessageId >, Pointer< Message >, MessageId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< ConnectionId >, Pointer< ConnectionState >, ConnectionId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< ConsumerId >, Pointer< ConsumerState >, ConsumerId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< SessionId >, Pointer< SessionState >, SessionId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< LocalTransactionId >, Pointer< TransactionState >, LocalTransactionId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< ProducerId >, Pointer< ProducerState >, ProducerId::COMPARATOR >, decaf::util::concurrent::CopyOnWriteArrayList< ServiceListener * >, decaf::util::StlMap< cms::Session *, SessionResolver * >, decaf::util::StlMap< std::string, WireFormatFactory * >, decaf::util::StlMap< decaf::lang::Runnable *, decaf::util::TimerTask * >, decaf::util::StlMap< std::string, PrimitiveValueNode >, decaf::util::StlMap< std::string, cms::Queue * >, decaf::util::StlMap< std::string, CachedConsumer * >, decaf::util::StlMap< Pointer< commands::ConsumerId >, ActiveMQConsumer *, commands::ConsumerId::COMPARATOR >, decaf::util::StlMap< std::string, TransportFactory * >, decaf::util::StlMap< Pointer< ConsumerId >, Pointer< ConsumerInfo >, ConsumerId::COMPARATOR >, decaf::util::StlMap< int, Pointer< Command > >, decaf::util::StlMap< std::string, CachedProducer * >, and decaf::util::StlMap< std::string, cms::Topic * >.
virtual bool decaf::util::concurrent::Synchronizable::tryLock | ( | ) | [pure virtual] |
Attempts to Lock the object, if the lock is already held by another thread than this method returns false.
RuntimeException | if an error occurs while locking the object. |
Implemented in activemq::core::FifoMessageDispatchChannel, activemq::core::SimplePriorityMessageDispatchChannel, decaf::internal::util::concurrent::SynchronizableImpl, decaf::io::InputStream, decaf::io::OutputStream, decaf::util::AbstractCollection< E >, decaf::util::concurrent::ConcurrentStlMap< K, V, COMPARATOR >, decaf::util::concurrent::CopyOnWriteArrayList< E >, decaf::util::concurrent::Mutex, decaf::util::StlMap< K, V, COMPARATOR >, decaf::util::StlQueue< T >, decaf::util::AbstractCollection< Pointer< Transport > >, decaf::util::AbstractCollection< Pointer< Synchronization > >, decaf::util::AbstractCollection< Resource * >, decaf::util::AbstractCollection< cms::MessageConsumer * >, decaf::util::AbstractCollection< CompositeTask * >, decaf::util::AbstractCollection< URI >, decaf::util::AbstractCollection< Pointer< MessageDispatch > >, decaf::util::AbstractCollection< Pointer< DestinationInfo > >, decaf::util::AbstractCollection< PrimitiveValueNode >, decaf::util::AbstractCollection< Pointer< Command > >, decaf::util::AbstractCollection< Pointer< BackupTransport > >, decaf::util::AbstractCollection< cms::MessageProducer * >, decaf::util::AbstractCollection< cms::Destination * >, decaf::util::AbstractCollection< cms::Session * >, decaf::util::AbstractCollection< cms::Connection * >, decaf::util::concurrent::ConcurrentStlMap< Pointer< MessageId >, Pointer< Message >, MessageId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< ConnectionId >, Pointer< ConnectionState >, ConnectionId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< ConsumerId >, Pointer< ConsumerState >, ConsumerId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< SessionId >, Pointer< SessionState >, SessionId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< LocalTransactionId >, Pointer< TransactionState >, LocalTransactionId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< ProducerId >, Pointer< ProducerState >, ProducerId::COMPARATOR >, decaf::util::concurrent::CopyOnWriteArrayList< ServiceListener * >, decaf::util::StlMap< cms::Session *, SessionResolver * >, decaf::util::StlMap< std::string, WireFormatFactory * >, decaf::util::StlMap< decaf::lang::Runnable *, decaf::util::TimerTask * >, decaf::util::StlMap< std::string, PrimitiveValueNode >, decaf::util::StlMap< std::string, cms::Queue * >, decaf::util::StlMap< std::string, CachedConsumer * >, decaf::util::StlMap< Pointer< commands::ConsumerId >, ActiveMQConsumer *, commands::ConsumerId::COMPARATOR >, decaf::util::StlMap< std::string, TransportFactory * >, decaf::util::StlMap< Pointer< ConsumerId >, Pointer< ConsumerInfo >, ConsumerId::COMPARATOR >, decaf::util::StlMap< int, Pointer< Command > >, decaf::util::StlMap< std::string, CachedProducer * >, and decaf::util::StlMap< std::string, cms::Topic * >.
virtual void decaf::util::concurrent::Synchronizable::unlock | ( | ) | [pure virtual] |
Unlocks the object.
RuntimeException | if an error occurs while unlocking the object. |
Implemented in activemq::core::FifoMessageDispatchChannel, activemq::core::SimplePriorityMessageDispatchChannel, decaf::internal::util::concurrent::SynchronizableImpl, decaf::io::InputStream, decaf::io::OutputStream, decaf::util::AbstractCollection< E >, decaf::util::concurrent::ConcurrentStlMap< K, V, COMPARATOR >, decaf::util::concurrent::CopyOnWriteArrayList< E >, decaf::util::concurrent::Mutex, decaf::util::StlMap< K, V, COMPARATOR >, decaf::util::StlQueue< T >, decaf::util::AbstractCollection< Pointer< Transport > >, decaf::util::AbstractCollection< Pointer< Synchronization > >, decaf::util::AbstractCollection< Resource * >, decaf::util::AbstractCollection< cms::MessageConsumer * >, decaf::util::AbstractCollection< CompositeTask * >, decaf::util::AbstractCollection< URI >, decaf::util::AbstractCollection< Pointer< MessageDispatch > >, decaf::util::AbstractCollection< Pointer< DestinationInfo > >, decaf::util::AbstractCollection< PrimitiveValueNode >, decaf::util::AbstractCollection< Pointer< Command > >, decaf::util::AbstractCollection< Pointer< BackupTransport > >, decaf::util::AbstractCollection< cms::MessageProducer * >, decaf::util::AbstractCollection< cms::Destination * >, decaf::util::AbstractCollection< cms::Session * >, decaf::util::AbstractCollection< cms::Connection * >, decaf::util::concurrent::ConcurrentStlMap< Pointer< MessageId >, Pointer< Message >, MessageId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< ConnectionId >, Pointer< ConnectionState >, ConnectionId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< ConsumerId >, Pointer< ConsumerState >, ConsumerId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< SessionId >, Pointer< SessionState >, SessionId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< LocalTransactionId >, Pointer< TransactionState >, LocalTransactionId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< ProducerId >, Pointer< ProducerState >, ProducerId::COMPARATOR >, decaf::util::concurrent::CopyOnWriteArrayList< ServiceListener * >, decaf::util::StlMap< cms::Session *, SessionResolver * >, decaf::util::StlMap< std::string, WireFormatFactory * >, decaf::util::StlMap< decaf::lang::Runnable *, decaf::util::TimerTask * >, decaf::util::StlMap< std::string, PrimitiveValueNode >, decaf::util::StlMap< std::string, cms::Queue * >, decaf::util::StlMap< std::string, CachedConsumer * >, decaf::util::StlMap< Pointer< commands::ConsumerId >, ActiveMQConsumer *, commands::ConsumerId::COMPARATOR >, decaf::util::StlMap< std::string, TransportFactory * >, decaf::util::StlMap< Pointer< ConsumerId >, Pointer< ConsumerInfo >, ConsumerId::COMPARATOR >, decaf::util::StlMap< int, Pointer< Command > >, decaf::util::StlMap< std::string, CachedProducer * >, and decaf::util::StlMap< std::string, cms::Topic * >.
virtual void decaf::util::concurrent::Synchronizable::wait | ( | ) | [pure virtual] |
Waits on a signal from this object, which is generated by a call to Notify.
Must have this object locked before calling.
RuntimeException | if an error occurs while waiting on the object. |
InterruptedException | if the wait is interrupted before it completes. |
IllegalMonitorStateException | - if the current thread is not the owner of the the Synchronizable Object. |
Implemented in activemq::core::FifoMessageDispatchChannel, activemq::core::SimplePriorityMessageDispatchChannel, decaf::internal::util::concurrent::SynchronizableImpl, decaf::io::InputStream, decaf::io::OutputStream, decaf::util::AbstractCollection< E >, decaf::util::concurrent::ConcurrentStlMap< K, V, COMPARATOR >, decaf::util::concurrent::CopyOnWriteArrayList< E >, decaf::util::concurrent::Mutex, decaf::util::StlMap< K, V, COMPARATOR >, decaf::util::StlQueue< T >, decaf::util::AbstractCollection< Pointer< Transport > >, decaf::util::AbstractCollection< Pointer< Synchronization > >, decaf::util::AbstractCollection< Resource * >, decaf::util::AbstractCollection< cms::MessageConsumer * >, decaf::util::AbstractCollection< CompositeTask * >, decaf::util::AbstractCollection< URI >, decaf::util::AbstractCollection< Pointer< MessageDispatch > >, decaf::util::AbstractCollection< Pointer< DestinationInfo > >, decaf::util::AbstractCollection< PrimitiveValueNode >, decaf::util::AbstractCollection< Pointer< Command > >, decaf::util::AbstractCollection< Pointer< BackupTransport > >, decaf::util::AbstractCollection< cms::MessageProducer * >, decaf::util::AbstractCollection< cms::Destination * >, decaf::util::AbstractCollection< cms::Session * >, decaf::util::AbstractCollection< cms::Connection * >, decaf::util::concurrent::ConcurrentStlMap< Pointer< MessageId >, Pointer< Message >, MessageId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< ConnectionId >, Pointer< ConnectionState >, ConnectionId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< ConsumerId >, Pointer< ConsumerState >, ConsumerId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< SessionId >, Pointer< SessionState >, SessionId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< LocalTransactionId >, Pointer< TransactionState >, LocalTransactionId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< ProducerId >, Pointer< ProducerState >, ProducerId::COMPARATOR >, decaf::util::concurrent::CopyOnWriteArrayList< ServiceListener * >, decaf::util::StlMap< cms::Session *, SessionResolver * >, decaf::util::StlMap< std::string, WireFormatFactory * >, decaf::util::StlMap< decaf::lang::Runnable *, decaf::util::TimerTask * >, decaf::util::StlMap< std::string, PrimitiveValueNode >, decaf::util::StlMap< std::string, cms::Queue * >, decaf::util::StlMap< std::string, CachedConsumer * >, decaf::util::StlMap< Pointer< commands::ConsumerId >, ActiveMQConsumer *, commands::ConsumerId::COMPARATOR >, decaf::util::StlMap< std::string, TransportFactory * >, decaf::util::StlMap< Pointer< ConsumerId >, Pointer< ConsumerInfo >, ConsumerId::COMPARATOR >, decaf::util::StlMap< int, Pointer< Command > >, decaf::util::StlMap< std::string, CachedProducer * >, and decaf::util::StlMap< std::string, cms::Topic * >.
virtual void decaf::util::concurrent::Synchronizable::wait | ( | long long | millisecs | ) | [pure virtual] |
Waits on a signal from this object, which is generated by a call to Notify.
Must have this object locked before calling. This wait will timeout after the specified time interval.
millisecs | the time in milliseconds to wait, or WAIT_INIFINITE |
RuntimeException | if an error occurs while waiting on the object. |
InterruptedException | if the wait is interrupted before it completes. |
IllegalMonitorStateException | - if the current thread is not the owner of the the Synchronizable Object. |
Implemented in activemq::core::FifoMessageDispatchChannel, activemq::core::SimplePriorityMessageDispatchChannel, decaf::internal::util::concurrent::SynchronizableImpl, decaf::io::InputStream, decaf::io::OutputStream, decaf::util::AbstractCollection< E >, decaf::util::concurrent::ConcurrentStlMap< K, V, COMPARATOR >, decaf::util::concurrent::CopyOnWriteArrayList< E >, decaf::util::concurrent::Mutex, decaf::util::StlMap< K, V, COMPARATOR >, decaf::util::StlQueue< T >, decaf::util::AbstractCollection< Pointer< Transport > >, decaf::util::AbstractCollection< Pointer< Synchronization > >, decaf::util::AbstractCollection< Resource * >, decaf::util::AbstractCollection< cms::MessageConsumer * >, decaf::util::AbstractCollection< CompositeTask * >, decaf::util::AbstractCollection< URI >, decaf::util::AbstractCollection< Pointer< MessageDispatch > >, decaf::util::AbstractCollection< Pointer< DestinationInfo > >, decaf::util::AbstractCollection< PrimitiveValueNode >, decaf::util::AbstractCollection< Pointer< Command > >, decaf::util::AbstractCollection< Pointer< BackupTransport > >, decaf::util::AbstractCollection< cms::MessageProducer * >, decaf::util::AbstractCollection< cms::Destination * >, decaf::util::AbstractCollection< cms::Session * >, decaf::util::AbstractCollection< cms::Connection * >, decaf::util::concurrent::ConcurrentStlMap< Pointer< MessageId >, Pointer< Message >, MessageId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< ConnectionId >, Pointer< ConnectionState >, ConnectionId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< ConsumerId >, Pointer< ConsumerState >, ConsumerId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< SessionId >, Pointer< SessionState >, SessionId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< LocalTransactionId >, Pointer< TransactionState >, LocalTransactionId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< ProducerId >, Pointer< ProducerState >, ProducerId::COMPARATOR >, decaf::util::concurrent::CopyOnWriteArrayList< ServiceListener * >, decaf::util::StlMap< cms::Session *, SessionResolver * >, decaf::util::StlMap< std::string, WireFormatFactory * >, decaf::util::StlMap< decaf::lang::Runnable *, decaf::util::TimerTask * >, decaf::util::StlMap< std::string, PrimitiveValueNode >, decaf::util::StlMap< std::string, cms::Queue * >, decaf::util::StlMap< std::string, CachedConsumer * >, decaf::util::StlMap< Pointer< commands::ConsumerId >, ActiveMQConsumer *, commands::ConsumerId::COMPARATOR >, decaf::util::StlMap< std::string, TransportFactory * >, decaf::util::StlMap< Pointer< ConsumerId >, Pointer< ConsumerInfo >, ConsumerId::COMPARATOR >, decaf::util::StlMap< int, Pointer< Command > >, decaf::util::StlMap< std::string, CachedProducer * >, and decaf::util::StlMap< std::string, cms::Topic * >.
virtual void decaf::util::concurrent::Synchronizable::wait | ( | long long | millisecs, |
int | nanos | ||
) | [pure virtual] |
Waits on a signal from this object, which is generated by a call to Notify.
Must have this object locked before calling. This wait will timeout after the specified time interval. This method is similar to the one argument wait function except that it add a finer grained control over the amount of time that it waits by adding in the additional nanosecond argument.
NOTE: The ability to wait accurately at a nanosecond scale depends on the platform and OS that the Decaf API is running on, some systems do not provide an accurate enough clock to provide this level of granularity.
millisecs | the time in milliseconds to wait, or WAIT_INIFINITE |
nanos | additional time in nanoseconds with a range of 0-999999 |
IllegalArgumentException | if an error occurs or the nanos argument is not in the range of [0-999999] |
RuntimeException | if an error occurs while waiting on the object. |
InterruptedException | if the wait is interrupted before it completes. |
IllegalMonitorStateException | - if the current thread is not the owner of the the Synchronizable Object. |
Implemented in activemq::core::FifoMessageDispatchChannel, activemq::core::SimplePriorityMessageDispatchChannel, decaf::internal::util::concurrent::SynchronizableImpl, decaf::io::InputStream, decaf::io::OutputStream, decaf::util::AbstractCollection< E >, decaf::util::concurrent::ConcurrentStlMap< K, V, COMPARATOR >, decaf::util::concurrent::CopyOnWriteArrayList< E >, decaf::util::concurrent::Mutex, decaf::util::StlMap< K, V, COMPARATOR >, decaf::util::StlQueue< T >, decaf::util::AbstractCollection< Pointer< Transport > >, decaf::util::AbstractCollection< Pointer< Synchronization > >, decaf::util::AbstractCollection< Resource * >, decaf::util::AbstractCollection< cms::MessageConsumer * >, decaf::util::AbstractCollection< CompositeTask * >, decaf::util::AbstractCollection< URI >, decaf::util::AbstractCollection< Pointer< MessageDispatch > >, decaf::util::AbstractCollection< Pointer< DestinationInfo > >, decaf::util::AbstractCollection< PrimitiveValueNode >, decaf::util::AbstractCollection< Pointer< Command > >, decaf::util::AbstractCollection< Pointer< BackupTransport > >, decaf::util::AbstractCollection< cms::MessageProducer * >, decaf::util::AbstractCollection< cms::Destination * >, decaf::util::AbstractCollection< cms::Session * >, decaf::util::AbstractCollection< cms::Connection * >, decaf::util::concurrent::ConcurrentStlMap< Pointer< MessageId >, Pointer< Message >, MessageId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< ConnectionId >, Pointer< ConnectionState >, ConnectionId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< ConsumerId >, Pointer< ConsumerState >, ConsumerId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< SessionId >, Pointer< SessionState >, SessionId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< LocalTransactionId >, Pointer< TransactionState >, LocalTransactionId::COMPARATOR >, decaf::util::concurrent::ConcurrentStlMap< Pointer< ProducerId >, Pointer< ProducerState >, ProducerId::COMPARATOR >, decaf::util::concurrent::CopyOnWriteArrayList< ServiceListener * >, decaf::util::StlMap< cms::Session *, SessionResolver * >, decaf::util::StlMap< std::string, WireFormatFactory * >, decaf::util::StlMap< decaf::lang::Runnable *, decaf::util::TimerTask * >, decaf::util::StlMap< std::string, PrimitiveValueNode >, decaf::util::StlMap< std::string, cms::Queue * >, decaf::util::StlMap< std::string, CachedConsumer * >, decaf::util::StlMap< Pointer< commands::ConsumerId >, ActiveMQConsumer *, commands::ConsumerId::COMPARATOR >, decaf::util::StlMap< std::string, TransportFactory * >, decaf::util::StlMap< Pointer< ConsumerId >, Pointer< ConsumerInfo >, ConsumerId::COMPARATOR >, decaf::util::StlMap< int, Pointer< Command > >, decaf::util::StlMap< std::string, CachedProducer * >, and decaf::util::StlMap< std::string, cms::Topic * >.