Examples of org.menagerie.latches.spi.ZkSemaphore.tryAcquire()

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

273 274 275 276 277 278 279 280 281 282 283     }     @Test(timeout = 1000l)     public void testTryAcquire() throws Exception{         DistributedSemaphore semaphore = new ZkSemaphore(2,basePath,zkSessionManager);         assertTrue("Semaphore did not acquire!",semaphore.tryAcquire());     }     @Test(timeout = 1000l)     public void testTryAcquireTimesOut() throws Exception{         final CountDownLatch latch = new CountDownLatch(1);

View Full Code Here

280 281 282 283 284 285 286 287 288 289 290     @Test(timeout = 1000l)     public void testTryAcquireTimesOut() throws Exception{         final CountDownLatch latch = new CountDownLatch(1);         final DistributedSemaphore semaphore = new ZkSemaphore(1,basePath,zkSessionManager);         assertTrue("Semaphore did not acquire!",semaphore.tryAcquire());         Future<Void> errorFuture = testService.submit(new Callable<Void>() {             @Override             public Void call() throws Exception {                 semaphore.tryAcquire(500, TimeUnit.MILLISECONDS);

View Full Code Here

285 286 287 288 289 290 291 292 293 294 295         assertTrue("Semaphore did not acquire!",semaphore.tryAcquire());         Future<Void> errorFuture = testService.submit(new Callable<Void>() {             @Override             public Void call() throws Exception {                 semaphore.tryAcquire(500, TimeUnit.MILLISECONDS);                 latch.countDown();                 return null;             }         });

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.