VisualSapfor/src/Common/Utils/InterruptThread.java

package Common.Utils;
import Common.Constants;
import org.apache.commons.io.FileUtils;

import java.io.File;
import java.util.concurrent.Callable;
public class InterruptThread extends Thread{
    //------------
    public InterruptThread(int sleep_ms, Callable action){
        super(() -> {
            File interruptFile = new File(Constants.INTERRUPT);
            try {
                while (true) {
                    Thread.sleep(sleep_ms);
                    if (interruptFile.exists()) {
                        FileUtils.writeStringToFile(new File(Constants.ABORTED), "");
                        FileUtils.forceDelete(interruptFile);
                        action.call();
                    }
                }
            } catch (Exception ex) {
                ex.printStackTrace();
            }
        });
    }
}