Edit

CountDownLatch

IgniteCountDownLatch provides functionality that is similar to that of java.util.concurrent.CountDownLatch and allows you to synchronize operations accross cluster nodes.

A distributed CountDownLatch can be created as follows:

Ignite ignite = Ignition.start();

IgniteCountDownLatch latch = ignite.countDownLatch("latchName", // Latch name.
        10, // Initial count.
        false, // Auto remove, when counter has reached zero.
        true // Create if it does not exist.
);

After the above code is executed, all nodes in the specified cache will be able to synchronize on the latch named latchName. Below is a code example of such synchronization:

Ignite ignite = Ignition.start();

final IgniteCountDownLatch latch = ignite.countDownLatch("latchName", 10, false, true);

// Execute jobs.
for (int i = 0; i < 10; i++)
    // Execute a job on some remote cluster node.
    ignite.compute().run(() -> {
        int newCnt = latch.countDown();

        System.out.println("Counted down: newCnt=" + newCnt);
    });

// Wait for all jobs to complete.
latch.await();

© 2024 The Apache Software Foundation.
Apache, Apache Ignite, the Apache feather and the Apache Ignite logo are either registered trademarks or trademarks of The Apache Software Foundation.