List of tryPut() Examples

Examples of tryPut()

com.alibaba.otter.canal.store.memory.MemoryEventStoreWithBuffer.tryPut()
com.hazelcast.core.IMap.tryPut()
Tries to put the given key, value into this map within specified timeout value. If this method returns false, it means that the caller thread couldn't acquire the lock for the key within timeout duration, thus put operation is not successful.

Warning:
This method uses hashCode and equals of binary form of the key, not the actual implementations of hashCode and equals defined in key's class. @param key key of the entry @param value value of the entry @param timeout maximum time to wait @param timeunit time unit for the timeout @return true if the put is successful, falseotherwise. @throws NullPointerException if the specified key or value is null

Examples of com.alibaba.otter.canal.store.memory.MemoryEventStoreWithBuffer.tryPut()

        eventStore.cleanUntil(entrys1.getPositionRange().getEnd());
        sleep(50L);


        // 继续造数据
        for (int i = bufferSize / 2; i < bufferSize; i++) {
            boolean result = eventStore.tryPut(buildEvent("1", 1L, 1L + i));
            sleep(100L);
            Assert.assertTrue(result);
        }


        Events<Event> entrys2 = eventStore.tryGet(entrys1.getPositionRange().getEnd(), bufferSize);

View Full Code Here

Examples of com.hazelcast.core.IMap.tryPut()

            }
        }, 50);
        addOperation(operations, new Runnable() {
            public void run() {
                IMap map = hazelcast.getMap("myMap");
                map.tryPut(random.nextInt(SIZE), new Customer(random.nextInt(100), String.valueOf(random.nextInt(10000))), 10,
                        TimeUnit.MILLISECONDS);
            }
        }, 5);
        addOperation(operations, new Runnable() {
            public void run() {

View Full Code Here

Examples of com.hazelcast.core.IMap.tryPut()

            }
        }, 50);
        addOperation(operations, new Runnable() {
            public void run() {
                IMap map = hazelcast.getMap("myMap");
                map.tryPut(random.nextInt(SIZE), new Customer(random.nextInt(100), String.valueOf(random.nextInt(10000))), 10,
                        TimeUnit.MILLISECONDS);
            }
        }, 5);
        addOperation(operations, new Runnable() {
            public void run() {

View Full Code Here

Examples of com.hazelcast.core.IMap.tryPut()

    }


    @Test
    public void testTryPutRemove() throws Exception {
        final IMap map = createMap();
        assertTrue(map.tryPut("key1", "value1", 1, TimeUnit.SECONDS));
        assertTrue(map.tryPut("key2", "value2", 1, TimeUnit.SECONDS));
        map.lock("key1");
        map.lock("key2");


        final CountDownLatch latch = new CountDownLatch(2);

View Full Code Here

Examples of com.hazelcast.core.IMap.tryPut()


    @Test
    public void testTryPutRemove() throws Exception {
        final IMap map = createMap();
        assertTrue(map.tryPut("key1", "value1", 1, TimeUnit.SECONDS));
        assertTrue(map.tryPut("key2", "value2", 1, TimeUnit.SECONDS));
        map.lock("key1");
        map.lock("key2");


        final CountDownLatch latch = new CountDownLatch(2);

View Full Code Here

Examples of com.hazelcast.core.IMap.tryPut()


        final CountDownLatch latch = new CountDownLatch(2);


        new Thread() {
            public void run() {
                boolean result = map.tryPut("key1", "value3", 1, TimeUnit.SECONDS);
                if (!result) {
                    latch.countDown();
                }
            }
        }.start();

View Full Code Here

Examples of com.hazelcast.core.IMap.tryPut()

        assertEquals("value1", map.get("key1"));
        map.lock("key1");
        final CountDownLatch latch = new CountDownLatch(1);
        new Thread() {
            public void run() {
                map.tryPut("key1", "value2", 1, TimeUnit.SECONDS);
                latch.countDown();
            }
        }.start();
        assertTrue(latch.await(5, TimeUnit.SECONDS));
        assertEquals("value1", map.get("key1"));

View Full Code Here

Examples of com.hazelcast.core.IMap.tryPut()

        assertEquals("value1", map.get("key1"));
        map.lock("key1", 2, TimeUnit.SECONDS);
        final CountDownLatch latch = new CountDownLatch(1);
        new Thread() {
            public void run() {
                map.tryPut("key1", "value2", 5, TimeUnit.SECONDS);
                latch.countDown();
            }
        }.start();
        assertTrue(latch.await(10, TimeUnit.SECONDS));
        assertFalse(map.isLocked("key1"));

View Full Code Here

Examples of com.hazelcast.core.IMap.tryPut()

    public void testTryPut_whenNotLocked() throws Exception {
        final IMap map = client.getMap(randomString());
        final Object key = "Key";
        final Object value = "value";


        boolean result = map.tryPut(key, value, 1, TimeUnit.SECONDS);


        assertTrue(result);
        assertEquals(value, map.get(key));
    }

View Full Code Here

Examples of com.hazelcast.core.IMap.tryPut()

        final Object key = "Key";
        final Object oldValue = "oldValue";
        final Object newValue = "Val";


        map.put(key, oldValue);
        boolean result = map.tryPut(key, newValue, 1, TimeUnit.SECONDS);


        assertTrue(result);
        assertEquals(newValue, map.get(key));
    }

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.