A service thread that polls the command queue

CommandQueuePollingExecutor.java

public class Test {

	public static void main(String[] args) {
		Thread t = new Thread(new Executor());
		t.start();
		System.out.println("I'm from the main thread!");
		Thread.sleep(5000);
		try {
			System.out.println("Interrupting another thread...");
			t.interrupt();
			System.out.println("Success!");
		}
		catch(Exception e) {
			System.out.println("Failed: " + e.getMessage());
		}
	}
	
	static class Executor implements Runnable {
		@Override
		public void run() {
			while (!Thread.currentThread().isInterrupted()) {
				try {
					Thread.sleep(1000);
				} catch(Exception e) {
					break;
				}
				System.out.println("I'm from another thread!");
			}
		}
	}
}