Java : BrokenBarrierException with Examples

April 2, 2025

Español/日本語/简体中文

BrokenBarrierException (Java SE 23 & JDK 23) in Java with Examples.
You will find code samples for most of the BrokenBarrierException methods.

Summary

final var barrier = new CyclicBarrier(3);
System.out.println("parties = " + barrier.getParties());

try (final var executor = Executors.newFixedThreadPool(3)) {

    final var futureA = executor.submit(() -> {
        try {
            System.out.println("A : task start");
            barrier.await();
        } catch (InterruptedException | BrokenBarrierException e) {
            System.out.println("A : " + e.getClass().getSimpleName());
        }
    });

    TimeUnit.SECONDS.sleep(1);

    executor.submit(() -> {
        try {
            System.out.println("B : task start");
            barrier.await();
        } catch (InterruptedException | BrokenBarrierException e) {
            System.out.println("B : " + e.getClass().getSimpleName());
        }
    });

    TimeUnit.SECONDS.sleep(1);

    System.out.println("task A cancel!");

    final var ret = futureA.cancel(true);
    System.out.println("cancelled = " + ret);
}

// Result
// ↓
//parties = 3
//A : task start
//B : task start
//task A cancel!
//A : InterruptedException
//B : BrokenBarrierException
//cancelled = true

Constructors

final var e = new BrokenBarrierException();
System.out.println(e); // java.util.concurrent.BrokenBarrierException

final var e = new BrokenBarrierException("abc");
System.out.println(e); // java.util.concurrent.BrokenBarrierException: abc
System.out.println(e.getMessage()); // abc

Methods declared in Throwable

Related posts

• Use TimeUnit.sleep instead of Thread.sleep

• API Examples
  • BlockingQueue
    • ArrayBlockingQueue
    • BlockingDeque
    • LinkedBlockingDeque
    • LinkedBlockingQueue
    • PriorityBlockingQueue
  • Callable
  • CancellationException
  • ConcurrentHashMap.KeySetView
  • ConcurrentLinkedDeque
  • ConcurrentLinkedQueue
  • ConcurrentMap
    • ConcurrentHashMap
    • ConcurrentSkipListMap
  • ConcurrentModificationException
  • ConcurrentSkipListSet
  • Condition
  • CopyOnWriteArrayList
  • CopyOnWriteArraySet
  • CountDownLatch
  • CyclicBarrier
  • Exchanger
  • ExecutionException
  • Executor
  • ExecutorService
  • Executors
  • Future
  • Future.State
  • FutureTask
  • InterruptedException
  • Lock
    • ReentrantLock
  • Runnable
  • Semaphore
  • Thread
  • ThreadGroup
  • ThreadLocal
    • InheritableThreadLocal
  • TimeoutException
  • TimeUnit