class ShutdownableThread extends Thread {

    public void forceShutdown() throws InterruptedException {
        log.info("Forcing shutdown of thread {}", getName());
        isRunning.set(false);
        interrupt();
    }

    public  ShutdownableThread(String name);
    public  ShutdownableThread(String name, boolean daemon);

}