Package EDU.oswego.cs.dl.util.concurrent

Examples of EDU.oswego.cs.dl.util.concurrent.ReentrantLock

79
80
81
82
83
84
85
86
87
88
89
     * Create the CommandManager
     */
    public CommandManager() {
        m_queue = new DefaultQueue();
        m_signalHandlers = new HashMap();
        m_mutex = new ReentrantLock();
        m_eventHandler = new CommandEventHandler(Collections.unmodifiableMap(m_signalHandlers));
        m_sources = new Source[]{m_queue};
        m_failureHandler = NullCommandFailureHandler.SHARED_INSTANCE;
        m_queue.setEnqueuePredicate(this);
        m_isAccepting = true;
View Full Code Here
50
51
52
53
54
55
56
    {
        if( size < 1 )
            throw new IllegalArgumentException( "Cannot specify an unbounded Queue" );

        m_elements = new Object[ size + 1 ];
        m_mutex = new ReentrantLock();
    }
View Full Code Here
55
56
57
58
59
60
61
62
63
64
    public DefaultQueue( EnqueuePredicate predicate )
    {
        setEnqueuePredicate( predicate );

        m_mutex = new ReentrantLock();
        m_elements = new UnboundedFifoBuffer();
        m_reserve = 0;
        m_maxSize = -1;
    }
View Full Code Here
46
47
48
49
50
51
52
   public Lock( LockManager lockManager,
                Object      key )
   {
      m_lockManager    = lockManager;
      m_key            = key;
      m_lock           = new ReentrantLock(  );
   }
View Full Code Here
TOP

Related Classes of EDU.oswego.cs.dl.util.concurrent.ReentrantLock

  • EDU.oswego.cs.dl.util.concurrent.misc.RlockRNG
  • org.apache.excalibur.event.command.CommandManager
  • org.apache.excalibur.event.impl.DefaultQueue
  • org.apache.excalibur.event.impl.FixedSizeQueue
  • org.apache.ws.util.lock.Lock
  • org.jgroups.tests.ReentrantLockTest
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.