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

            Assert.assertTrue(result);
        } catch (Exception e) {
            Assert.fail(e.getMessage());
        }
        // 尝试
        result = eventStore.tryPut(buildEvent("1", 1L, 1L));
        Assert.assertTrue(result);


        eventStore.stop();
    }

View Full Code Here

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

        MemoryEventStoreWithBuffer eventStore = new MemoryEventStoreWithBuffer();
        eventStore.setBufferSize(bufferSize);
        eventStore.start();


        for (int i = 0; i < bufferSize; i++) {
            boolean result = eventStore.tryPut(buildEvent("1", 1L, 1L + i));
            Assert.assertTrue(result);
        }


        boolean result = eventStore.tryPut(buildEvent("1", 1L, 1L + bufferSize));
        Assert.assertFalse(result);

View Full Code Here

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

        for (int i = 0; i < bufferSize; i++) {
            boolean result = eventStore.tryPut(buildEvent("1", 1L, 1L + i));
            Assert.assertTrue(result);
        }


        boolean result = eventStore.tryPut(buildEvent("1", 1L, 1L + bufferSize));
        Assert.assertFalse(result);


        try {
            result = eventStore.put(buildEvent("1", 1L, 1L + bufferSize), 1000L, TimeUnit.MILLISECONDS);
        } catch (CanalStoreException e) {

View Full Code Here

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

    @Test
    public void testOnePutOneGet() {
        MemoryEventStoreWithBuffer eventStore = new MemoryEventStoreWithBuffer();
        eventStore.start();


        boolean result = eventStore.tryPut(buildEvent("1", 1L, 1L));
        Assert.assertTrue(result);


        Position position = eventStore.getFirstPosition();
        Events<Event> entrys = eventStore.tryGet(position, 1);
        Assert.assertTrue(entrys.getEvents().size() == 1);

View Full Code Here

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

        MemoryEventStoreWithBuffer eventStore = new MemoryEventStoreWithBuffer();
        eventStore.setBufferSize(bufferSize);
        eventStore.start();


        for (int i = 0; i < bufferSize; i++) {
            boolean result = eventStore.tryPut(buildEvent("1", 1L, 1L + i));
            sleep(100L);
            Assert.assertTrue(result);
        }


        Position first = eventStore.getFirstPosition();

View Full Code Here

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

        final MemoryEventStoreWithBuffer eventStore = new MemoryEventStoreWithBuffer();
        eventStore.start();


        final int batchSize = 10;
        for (int i = 0; i < batchSize; i++) {
            boolean result = eventStore.tryPut(buildEvent("1", 1L, 1L));
            Assert.assertTrue(result);
        }


        final Position position = eventStore.getFirstPosition();
        try {

View Full Code Here

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

        MemoryEventStoreWithBuffer eventStore = new MemoryEventStoreWithBuffer();
        eventStore.setBufferSize(bufferSize);
        eventStore.start();


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


        sleep(50L);

View Full Code Here

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

        System.out.println("after rollback get size : " + entrys1.getEvents().size());
        Assert.assertTrue(entrys1.getEvents().size() == bufferSize / 2);


        // 继续造数据
        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.alibaba.otter.canal.store.memory.MemoryEventStoreWithBuffer.tryPut()

        MemoryEventStoreWithBuffer eventStore = new MemoryEventStoreWithBuffer();
        eventStore.setBufferSize(bufferSize);
        eventStore.start();


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


        sleep(50L);

View Full Code Here

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

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.