Package java.util.concurrent.locks.ReentrantReadWriteLock

Examples of java.util.concurrent.locks.ReentrantReadWriteLock.WriteLock.tryLock()

248
249
250
251
252
253
254
255
256
257
258
   
    WriteLock writeLock = job.getTrunkLock().writeLock();
   
    try
    {
      if (writeLock.tryLock(10, TimeUnit.MINUTES))
      {
        try
        {
          Map<String, Map<String, Object>> jobResult = job.getJobResult();
          if (jobResult != null)
View Full Code Here
414
415
416
417
418
419
420
421
422
423
424
   
    WriteLock writeLock = job.getTrunkLock().writeLock();
   
    try
    {
      if (writeLock.tryLock(10, TimeUnit.MINUTES))
      {
        try
        {
          Map<String, Map<String, Object>> jobResult = job.getJobResult();
          if (jobResult != null)
View Full Code Here
396
397
398
399
400
401
402
403
404
405
406
            // to avoid infinite blocking, we'll only wait for a set time (though long).

            WriteLock writeLock = m_needToCallInitializeCallbackLock.writeLock();
            boolean locked;
            try {
                locked = writeLock.tryLock(m_initializeCallbackLockAcquisitionTimeoutMins * 60, TimeUnit.SECONDS);
            } catch (InterruptedException ie) {
                Thread.currentThread().interrupt();
                locked = false;
            }

View Full Code Here
371
372
373
374
375
376
377
378
379
380
381
    @Override
    public LockHandle aquireWriteLock() {
        final WriteLock writeLock = readWriteLock.writeLock();
        boolean success;
        try {
            success = writeLock.tryLock() || writeLock.tryLock(AQUIRE_LOCK_TIMEOUT, TimeUnit.MILLISECONDS);
        } catch (InterruptedException ex) {
            success = false;
        }
        IllegalStateAssertion.assertTrue(success, "Cannot obtain profile write lock in time");
        return new LockHandle() {
View Full Code Here
371
372
373
374
375
376
377
378
379
380
381
    @Override
    public LockHandle aquireWriteLock() {
        final WriteLock writeLock = readWriteLock.writeLock();
        boolean success;
        try {
            success = writeLock.tryLock() || writeLock.tryLock(AQUIRE_LOCK_TIMEOUT, TimeUnit.MILLISECONDS);
        } catch (InterruptedException ex) {
            success = false;
        }
        IllegalStateAssertion.assertTrue(success, "Cannot obtain profile write lock in time");
        return new LockHandle() {
View Full Code Here
226
227
228
229
230
231
232
233
234
235
236
        }

        private WriteLock writeLock(long timeout, TimeUnit unit) {
            WriteLock lock = rwlock.writeLock();
            try {
                if (!lock.tryLock() && !lock.tryLock(timeout, unit))
                    throw new PermitStateTimeoutException("Cannot aquire write lock for [" + key.getName() + "] in time", key, timeout, unit);
            } catch (InterruptedException ex) {
                throw new IllegalStateException(ex);
            }
            return lock;
View Full Code Here
226
227
228
229
230
231
232
233
234
235
236
        }

        private WriteLock writeLock(long timeout, TimeUnit unit) {
            WriteLock lock = rwlock.writeLock();
            try {
                if (!lock.tryLock() && !lock.tryLock(timeout, unit))
                    throw new PermitStateTimeoutException("Cannot aquire write lock for [" + key.getName() + "] in time", key, timeout, unit);
            } catch (InterruptedException ex) {
                throw new IllegalStateException(ex);
            }
            return lock;
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.