List of trySetCount() Examples

Examples of trySetCount()

com.hazelcast.core.ICountDownLatch.trySetCount()
Sets the count to the given value if the current count is zero.
If count is not zero then this method does nothing and returns {@code false}. @param count the number of times {@link #countDown} must be invokedbefore threads can pass through {@link #await} @return {@code true} if the new count was set or {@code false} if the currentcount is not zero @throws IllegalArgumentException if {@code count} is negative
org.apache.curator.framework.recipes.shared.SharedCount.trySetCount()
Changes the shared count only if its value has not changed since this client last read it. If the count has changed, the value is not set and this client's view of the value is updated. i.e. if the count is not successful you can get the updated value by calling {@link #getCount()}. @deprecated use {@link #trySetCount(VersionedValue,int)} for stronger atomicityguarantees. Even if this object's internal state is up-to-date, the caller has no way to ensure that they've read the most recently seen count. @param newCount the new value to attempt @return true if the change attempt was successful, false if not. If the changewas not successful, {@link #getCount()} will return the updated value @throws Exception ZK errors, interruptions, etc.
org.redisson.core.RCountDownLatch.trySetCount()
Sets new count value only if previous count already has reached zero or not been setted at all. @param count the number of times {@link #countDown} must be invokedbefore threads can pass through {@link #await} @return true if new count settedfalse if previous count has not reached zero

Examples of com.hazelcast.core.ICountDownLatch.trySetCount()

    public void testAwait_withManyThreads() {
        HazelcastInstance instance = createHazelcastInstance();
        final ICountDownLatch latch = instance.getCountDownLatch(randomString());
        final CountDownLatch completedLatch = new CountDownLatch(10);


        latch.trySetCount(1);
        for (int i = 0; i < 10; i++) {
            new TestThread() {
                public void doRun() throws Exception {
                    if (latch.await(1, TimeUnit.MINUTES)) {
                        completedLatch.countDown();

View Full Code Here

Examples of com.hazelcast.core.ICountDownLatch.trySetCount()

    @Test(timeout = 15000)
    public void testAwait_whenTimeOut() throws InterruptedException {
        HazelcastInstance instance = createHazelcastInstance();
        ICountDownLatch latch = instance.getCountDownLatch(randomString());


        latch.trySetCount(1);
        long time = System.currentTimeMillis();
        assertFalse(latch.await(100, TimeUnit.MILLISECONDS));
        long elapsed = System.currentTimeMillis() - time;
        assertTrue(elapsed >= 100);
        assertEquals(1, latch.getCount());

View Full Code Here

Examples of com.hazelcast.core.ICountDownLatch.trySetCount()


    @Test
    public void testAwait_whenInstanceShutdown_thenHazelcastInstanceNotActiveException() throws InterruptedException {
        HazelcastInstance instance = createHazelcastInstance();
        final ICountDownLatch latch = instance.getCountDownLatch(randomString());
        latch.trySetCount(10);


        final TestThread awaitThread = new TestThread() {
            @Override
            public void doRun() throws Exception {
                latch.await(1, TimeUnit.HOURS);

View Full Code Here

Examples of com.hazelcast.core.ICountDownLatch.trySetCount()

    public void testCountDownLatch() throws Exception {
        String partitionKey = "hazelcast";
        HazelcastInstance hz = getHazelcastInstance(partitionKey);


        ICountDownLatch countDownLatch = hz.getCountDownLatch("countdownlatch@" + partitionKey);
        countDownLatch.trySetCount(1);
        assertEquals("countdownlatch@" + partitionKey, countDownLatch.getName());
        assertEquals(partitionKey, countDownLatch.getPartitionKey());


        CountDownLatchService service = getNodeEngine(hz).getService(CountDownLatchService.SERVICE_NAME);
        assertTrue(service.containsLatch(countDownLatch.getName()));

View Full Code Here

Examples of com.hazelcast.core.ICountDownLatch.trySetCount()

    }


    @Test(expected = IllegalArgumentException.class)
    public void testTrySetCount_whenArgumentNegative() {
        ICountDownLatch latch = hz.getCountDownLatch(randomString());
        latch.trySetCount(-20);
    }


    @Test
    public void testTrySetCount_whenCountIsNotZero() {
        ICountDownLatch latch = hz.getCountDownLatch(randomString());

View Full Code Here

Examples of com.hazelcast.core.ICountDownLatch.trySetCount()

    }


    @Test
    public void testTrySetCount_whenCountIsNotZero() {
        ICountDownLatch latch = hz.getCountDownLatch(randomString());
        latch.trySetCount(10);
        assertFalse(latch.trySetCount(20));
        assertFalse(latch.trySetCount(0));
        assertEquals(10, latch.getCount());
    }
}

View Full Code Here

Examples of com.hazelcast.core.ICountDownLatch.trySetCount()


    @Test
    public void testTrySetCount_whenCountIsNotZero() {
        ICountDownLatch latch = hz.getCountDownLatch(randomString());
        latch.trySetCount(10);
        assertFalse(latch.trySetCount(20));
        assertFalse(latch.trySetCount(0));
        assertEquals(10, latch.getCount());
    }
}

View Full Code Here

Examples of com.hazelcast.core.ICountDownLatch.trySetCount()

    @Test
    public void testTrySetCount_whenCountIsNotZero() {
        ICountDownLatch latch = hz.getCountDownLatch(randomString());
        latch.trySetCount(10);
        assertFalse(latch.trySetCount(20));
        assertFalse(latch.trySetCount(0));
        assertEquals(10, latch.getCount());
    }
}

View Full Code Here

Examples of com.hazelcast.core.ICountDownLatch.trySetCount()


    // Starting the countdown latch.
    ICountDownLatch countDownLatchForDeploy = context.getCoordinationStructures()
        .getCountDownLatchForDeploy(version);
    Set<String> dnodesInvolved = actionsPerDNode.keySet();
    countDownLatchForDeploy.trySetCount(dnodesInvolved.size());


    // Sending deploy signals to each DNode
    for(Map.Entry<String, List<DeployAction>> actionPerDNode : actionsPerDNode.entrySet()) {
      DNodeService.Client client = null;
      boolean renew = false;

View Full Code Here

Examples of org.apache.curator.framework.recipes.shared.SharedCount.trySetCount()

                        @Override
                        public Object call() throws Exception
                        {
                            Assert.assertTrue(latch.await(timing.forWaiting().seconds(), TimeUnit.SECONDS));
                            timing.sleepABit(); // make sure second acquire is waiting
                            Assert.assertTrue(count.trySetCount(2));
                            return null;
                        }
                    }
                );

View Full Code Here

0 1 2 3

TOP

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.