/*
 * Copyright 2014-2019 Real Logic Ltd.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package org.agrona.concurrent;

import sun.misc.Signal;

import java.util.ArrayList;
import java.util.concurrent.CountDownLatch;

/**
 * One time barrier for blocking one or more threads until a SIGINT or SIGTERM signal is received from the operating
 * system or by programmatically calling {@link #signal()}. Useful for shutting down a service.
 */
public class ShutdownSignalBarrier
{
    /**
     * Signals the barrier will be registered for.
     */
    public static final String[] SIGNAL_NAMES = { "INT", "TERM" };
    private static final ArrayList<CountDownLatch> LATCHES = new ArrayList<>();

    static
    {
        for (final String signalName : SIGNAL_NAMES)
        {
            Signal.handle(new Signal(signalName), (signal) -> LATCHES.forEach(CountDownLatch::countDown));
        }
    }

    private final CountDownLatch latch = new CountDownLatch(1);

    /**
     * Construct and register the barrier ready for use.
     */
    public ShutdownSignalBarrier()
    {
        synchronized (this)
        {
            LATCHES.add(latch);
        }
    }

    /**
     * Programmatically signal awaiting threads.
     */
    public void signal()
    {
        synchronized (this)
        {
            LATCHES.remove(latch);
            latch.countDown();
        }
    }

    /**
     * Remove the barrier from the shutdown signals.
     */
    public void remove()
    {
        synchronized (this)
        {
            LATCHES.remove(latch);
        }
    }

    /**
     * Await the reception of the shutdown signal.
     */
    public void await()
    {
        try
        {
            latch.await();
        }
        catch (final InterruptedException ignore)
        {
            Thread.currentThread().interrupt();
        }
    }
}

@@ -1593,36 +1593,39 @@
   synchronized (
-this
+LATCHES
 )%0A        %7B%0A    
@@ -1779,36 +1779,39 @@
   synchronized (
-this
+LATCHES
 )%0A        %7B%0A    
@@ -1881,32 +1881,278 @@
        %7D%0A    %7D%0A%0A
+    /**%0A     * Programmatically signal all awaiting threads.%0A     */%0A    public void signalAll()%0A    %7B%0A        synchronized (LATCHES)%0A        %7B%0A            LATCHES.forEach(CountDownLatch::countDown);%0A            LATCHES.clear();%0A        %7D%0A    %7D%0A%0A
     /**%0A     * R
@@ -2257,20 +2257,23 @@
 onized (
-this
+LATCHES
 )%0A      

Make synchronisation around shutdown latches more robust, add a method to signal all latches