package com.fireflysource.common.lifecycle;

import com.fireflysource.common.func.Callback;

import java.util.List;
import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.atomic.AtomicBoolean;

public abstract class AbstractLifeCycle implements LifeCycle {

    protected static final List<Callback> stopActions = new CopyOnWriteArrayList<>();

    static {
        try {
            Runtime.getRuntime().addShutdownHook(new Thread(() -> {
                stopActions.forEach(a -> {
                    try {
                        a.call();
                    } catch (Exception e) {
                        System.err.println(e.getMessage());
                    }
                });
                System.out.println("Shutdown instance: " + stopActions.size());
                stopActions.clear();
            }, "the firefly shutdown thread"));
        } catch (Exception e) {
            System.err.println(e.getMessage());
        }
    }

    protected AtomicBoolean start = new AtomicBoolean(false);

    public AbstractLifeCycle() {
        stopActions.add(this::stop);
    }

    @Override
    public boolean isStarted() {
        return start.get();
    }

    @Override
    public boolean isStopped() {
        return !start.get();
    }

    @Override
    public void start() {
        if (start.compareAndSet(false, true)) {
            init();
        }
    }

    @Override
    public void stop() {
        if (start.compareAndSet(true, false)) {
            destroy();
        }
    }

    abstract protected void init();

    abstract protected void destroy();

    public static void stopAll() {
        stopActions.forEach(Callback::call);
    }

}

@@ -452,395 +452,34 @@
 ead(
-() -%3E %7B%0A                stopActions.forEach(a -%3E %7B%0A                    try %7B%0A                        a.call();%0A                    %7D catch (Exception e) %7B%0A                        System.err.println(e.getMessage());%0A                    %7D%0A                %7D);%0A                System.out.println(%22Shutdown instance: %22 + stopActions.size());%0A                stopActions.clear();%0A            %7D
+AbstractLifeCycle::stopAll
 , %22t
@@ -1307,22 +1307,271 @@
 ach(
-Callback::call
+a -%3E %7B%0A            try %7B%0A                a.call();%0A            %7D catch (Exception e) %7B%0A                System.err.println(e.getMessage());%0A            %7D%0A        %7D);%0A        System.out.println(%22Shutdown instance: %22 + stopActions.size());%0A        stopActions.clear(
 );%0A 

add stop all method.