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()

    @Test
    public void testTrySetCount_whenPositive() {
        HazelcastInstance instance = createHazelcastInstance();
        ICountDownLatch latch = instance.getCountDownLatch(randomString());


        latch.trySetCount(10);
        assertFalse(latch.trySetCount(20));
        assertEquals(10, latch.getCount());
    }


    @Test

View Full Code Here

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

    public void testTrySetCount_whenPositive() {
        HazelcastInstance instance = createHazelcastInstance();
        ICountDownLatch latch = instance.getCountDownLatch(randomString());


        latch.trySetCount(10);
        assertFalse(latch.trySetCount(20));
        assertEquals(10, latch.getCount());
    }


    @Test
    public void testTrySetCount_whenAlreadySet() {

View Full Code Here

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

    @Test
    public void testTrySetCount_whenAlreadySet() {
        HazelcastInstance instance = createHazelcastInstance();
        ICountDownLatch latch = instance.getCountDownLatch(randomString());


        latch.trySetCount(10);
        assertFalse(latch.trySetCount(20));
        assertFalse(latch.trySetCount(100));
        assertFalse(latch.trySetCount(0));
        assertEquals(10, latch.getCount());
    }

View Full Code Here

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

    public void testTrySetCount_whenAlreadySet() {
        HazelcastInstance instance = createHazelcastInstance();
        ICountDownLatch latch = instance.getCountDownLatch(randomString());


        latch.trySetCount(10);
        assertFalse(latch.trySetCount(20));
        assertFalse(latch.trySetCount(100));
        assertFalse(latch.trySetCount(0));
        assertEquals(10, latch.getCount());
    }

View Full Code Here

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

        HazelcastInstance instance = createHazelcastInstance();
        ICountDownLatch latch = instance.getCountDownLatch(randomString());


        latch.trySetCount(10);
        assertFalse(latch.trySetCount(20));
        assertFalse(latch.trySetCount(100));
        assertFalse(latch.trySetCount(0));
        assertEquals(10, latch.getCount());
    }


    // ================= countDown =================================================

View Full Code Here

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

        ICountDownLatch latch = instance.getCountDownLatch(randomString());


        latch.trySetCount(10);
        assertFalse(latch.trySetCount(20));
        assertFalse(latch.trySetCount(100));
        assertFalse(latch.trySetCount(0));
        assertEquals(10, latch.getCount());
    }


    // ================= countDown =================================================

View Full Code Here

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

    @Test
    public void testCountDown() {
        HazelcastInstance instance = createHazelcastInstance();
        ICountDownLatch latch = instance.getCountDownLatch(randomString());


        latch.trySetCount(20);
        for (int i = 19; i >= 0; i--) {
            latch.countDown();
            assertEquals(i, latch.getCount());
        }
    }

View Full Code Here

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

    public void testCountDown_whenReachZero_thenLatchRemoved() {
        HazelcastInstance instance = createHazelcastInstance();
        ICountDownLatch latch = instance.getCountDownLatch(randomString());
        CountDownLatchService service = getNode(instance).getNodeEngine().getService(CountDownLatchService.SERVICE_NAME);


        latch.trySetCount(1);
        assertTrue(service.containsLatch(latch.getName()));
        latch.countDown();
        assertFalse(service.containsLatch(latch.getName()));
    }

View Full Code Here

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

    @Test
    public void testGetCount() {
        HazelcastInstance instance = createHazelcastInstance();
        ICountDownLatch latch = instance.getCountDownLatch(randomString());


        latch.trySetCount(20);
        assertEquals(20, latch.getCount());
    }


    // ================= destroy =================================================

View Full Code Here

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

    // ================= await =================================================
    @Test(timeout = 15000)
    public void testAwait() throws InterruptedException {
        HazelcastInstance instance = createHazelcastInstance();
        final ICountDownLatch latch = instance.getCountDownLatch(randomString());
        latch.trySetCount(1);
        TestThread thread = new TestThread() {
            public void doRun() {
                latch.countDown();
            }
        };

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.