Task Executor

WorkertThread.java

public class WorkerThread extends Thread {

    private final LinkedBlockingQueue<Runnable> tasks;
    private final AtomicBoolean cancelled;
    private final AtomicBoolean safeCanceled;

    public WorkerThread() {
        this.tasks = new LinkedBlockingQueue<>();
        this.cancelled = new AtomicBoolean(false);
        this.safeCanceled = new AtomicBoolean(false);
    }

    public boolean enqueueTask(Runnable task) {
        return tasks.offer(task);
    }

    public void terminate() {
        cancelled.getAndSet(true);
    }

    public void terminateSafely() {
        safeCanceled.getAndSet(true);
    }

    @Override
    public void run() {
        while(!cancelled.get()) {
            try {
                //wait for queue to be empty first
                if (tasks.size() == 0 && safeCanceled.get()) {
                    break;
                }
                Runnable task = tasks.take();
                task.run();
            } catch (InterruptedException e) {
                if (cancelled.get()) {
                    break;
                }
            }
        }
    }
}