List of tryAcquire() Examples

Examples of tryAcquire()

com.hazelcast.core.ISemaphore.tryAcquire()
Acquires a permit, if one is available and returns immediately, with the value {@code true}, reducing the number of available permits by one.
If no permit is available then this method will return immediately with the value {@code false}. @return {@code true} if a permit was acquired and {@code false}otherwise
java.util.concurrent.Semaphore.tryAcquire()
Acquires a permit from this semaphore, only if one is available at the time of invocation.
Acquires a permit, if one is available and returns immediately, with the value {@code true}, reducing the number of available permits by one.
If no permit is available then this method will return immediately with the value {@code false}.
Even when this semaphore has been set to use a fair ordering policy, a call to {@code tryAcquire()} willimmediately acquire a permit if one is available, whether or not other threads are currently waiting. This "barging" behavior can be useful in certain circumstances, even though it breaks fairness. If you want to honor the fairness setting, then use {@link #tryAcquire(long,TimeUnit) tryAcquire(0, TimeUnit.SECONDS) }which is almost equivalent (it also detects interruption). @return {@code true} if a permit was acquired and {@code false}otherwise
org.apache.hadoop.hbase.InterProcessLock.tryAcquire()
Acquire the lock within a wait time. @param timeoutMs The maximum time (in milliseconds) to wait for the lock,-1 to wait indefinitely @return True if the lock was acquired, false if waiting time elapsedbefore the lock was acquired @throws IOException If there is an unrecoverable error talking talking(e.g., when talking to a lock service) when acquiring the lock @throws InterruptedException If the thread is interrupted while waiting toacquire the lock
org.chromium.sdk.CallbackSemaphore.tryAcquire()
Tries to acquire the semaphore. This method blocks until the semaphore is released; typically release call comes from a worker thread of org.chromium.sdk, the same thread that may call all other callbacks. It is vital not to call this method from any callback of org.chromium.sdk, because it's a sure deadlock. To prevent, this the method declares throwing {@code MethodIsBlockingException} which is symbolically thrown wheneversomeone violates this rule (i.e. invokes this method from a callback). Though currently nobody actually throws it, such declarations help to track blocking methods. @return false if {@code timeout} was exceeded and we gave up @throws MethodIsBlockingException if called from a callback
org.menagerie.latches.spi.ZkSemaphore.tryAcquire()
Acquires a permit from this semaphore only if it is available at the time of invocation.
If a permit is immediately available, this method returns {@code true} immediately, reducing the number ofavailable permits in the semaphore by one.
If no permit is available then this method will return immediately with the value {@code false}.
Note: Unlike {@link java.util.concurrent.Semaphore#tryAcquire()}, this method will obey ordering policies, and will never acquire a permit at the expense of another party. @return true if a permit has been acquired, false otherwise

Examples of java.util.concurrent.Semaphore.tryAcquire()

184 185 186 187 188 189 190 191 192 193 194         Activator a = new Activator();         a.start(bctx);                 // Wait until the EndpointListener.endpointAdded call was made as the controlflow is asynchronous         sema.tryAcquire(30, TimeUnit.SECONDS);                 c.verify();     }

View Full Code Here

Examples of java.util.concurrent.Semaphore.tryAcquire()

62 63 64 65 66 67 68 69 70 71 72                 rsaList.add(rsa);                 tm.triggerExportImportForRemoteSericeAdmin(rsa);                 assertTrue(sema.tryAcquire(10, TimeUnit.SECONDS));                         tm.stop();                 c.verify();

View Full Code Here

Examples of java.util.concurrent.Semaphore.tryAcquire()

175 176 177 178 179 180 181 182 183 184 185                 semaphore.release();             }         }.start();         m_repository.writeLocal(in);         try {             if (!semaphore.tryAcquire(30, TimeUnit.SECONDS)) {                 throw new IOException("Error writing the contents of RepositoryUserAdmin.");             }         }         catch (InterruptedException e) {             Thread.currentThread().interrupt();

View Full Code Here

Examples of java.util.concurrent.Semaphore.tryAcquire()

1131 1132 1133 1134 1135 1136 1137 1138 1139 1140 1141                      }                      message.getBodyBuffer().writeBytes(new byte[50]);                      producer.send(message);                      assertTrue(semop.tryAcquire(1, 10, TimeUnit.SECONDS));                   }                }                catch (Throwable e)                {                   e.printStackTrace(System.out);

View Full Code Here

Examples of java.util.concurrent.Semaphore.tryAcquire()

434 435 436 437 438 439 440 441 442 443 444           try {             s.acquire();           } catch (InterruptedException ix) {}         } else {           try {             s.tryAcquire(graceperiod, TimeUnit.MILLISECONDS);           } catch (InterruptedException ix) {}         }       }       result = bpcRef.get();       st.close();

View Full Code Here

Examples of java.util.concurrent.Semaphore.tryAcquire()

423 424 425 426 427 428 429 430 431 432 433         creationSemaphore = new Semaphore(1, true);         socketCreationMap.put(key, creationSemaphore);       }     }     try {       boolean retval = creationSemaphore.tryAcquire(10, TimeUnit.SECONDS);       if (!retval) {         throw new IOException("Could not acquire IO Semaphore'" + key             + "' after 10 seconds -- giving up ");       }     } catch (InterruptedException e) {

View Full Code Here

Examples of java.util.concurrent.Semaphore.tryAcquire()

61 62 63 64 65 66 67 68 69 70 71                 semaphore.drainPermits();                 _semaphores.putIfAbsent(thread, semaphore);             }             semaphore = _semaphores.get(thread);             try {                 semaphore.tryAcquire(timeout, TimeUnit.MILLISECONDS);             } catch (InterruptedException exception) {                 logger.log(Level.FINER, "Exception ", exception);             }         }

View Full Code Here

Examples of java.util.concurrent.Semaphore.tryAcquire()

127 128 129 130 131 132 133 134 135 136 137                 int next = random.nextInt(100);                 countList.add(next);                 count.setCount(next);                 Assert.assertTrue(semaphore.tryAcquire(CLIENT_QTY, 10, TimeUnit.SECONDS));             }             count.setCount(-1);             for ( Future<List<Integer>> future : futures )             {

View Full Code Here

Examples of java.util.concurrent.Semaphore.tryAcquire()

583 584 585 586 587 588 589 590 591 592 593                 creationSemaphore = new Semaphore(1, true);                 socketCreationMap.put(key, creationSemaphore);             }         }         try {             boolean retval = creationSemaphore.tryAcquire(10, TimeUnit.SECONDS);             if (!retval) {                 throw new IOException("Could not acquire IO Semaphore'" + key                         + "' after 10 seconds -- giving up ");             }         } catch (InterruptedException e) {

View Full Code Here

Examples of java.util.concurrent.Semaphore.tryAcquire()

918 919 920 921 922 923 924 925 926 927 928             }         }         s.release(notOwnedCount);         try {             if (ok.get()) {                 return s.tryAcquire(partitionCount, 10, TimeUnit.SECONDS) && ok.get();             } else {                 return false;             }         } catch (InterruptedException ignored) {             return false;

View Full Code Here

0 1 2 3 4 5

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.