Starts using Future for background tasks

pom.xml

@@ -22,7 +22,7 @@
 		<dependency>
 			<groupId>com.fathzer</groupId>
 			<artifactId>games-core</artifactId>
-			<version>0.0.11-SNAPSHOT</version>
+			<version>0.0.12-SNAPSHOT</version>
 		</dependency>
 		<dependency>
 			<groupId>org.junit.jupiter</groupId>

src/test/java/com/fathzer/jchess/uci/util/FutureTricks.java

@@ -0,0 +1,54 @@
+package com.fathzer.jchess.uci.util;
+
+import static org.junit.jupiter.api.Assertions.*;
+
+import java.util.concurrent.Callable;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.Future;
+import java.util.concurrent.ThreadFactory;
+import java.util.concurrent.TimeUnit;
+
+import org.awaitility.Awaitility;
+import org.junit.jupiter.api.Test;
+
+import com.fathzer.games.util.exec.CustomThreadFactory;
+
+class FutureTricks {
+	private Thread currentThread;
+//	private static class MyCoolTask implements Callable()
+
+	@Test
+	void test() throws InterruptedException, ExecutionException {
+		final ThreadFactory threadFactory = new CustomThreadFactory(() -> "executorService", true);
+		ExecutorService svce = Executors.newSingleThreadExecutor(threadFactory);
+		Callable<String> task = () -> {
+			try {
+				currentThread = Thread.currentThread();
+				Thread.sleep(1000);
+			} catch (InterruptedException e) {
+				Thread.currentThread().interrupt();
+				return "I was interrupted";
+			}
+			return "Normal";
+		};
+
+		Future<String> future = svce.submit(task);
+		assertEquals("Normal", future.get());
+
+		future = svce.submit(task);
+		Awaitility.await().atLeast(100, TimeUnit.MILLISECONDS);
+		currentThread.interrupt();
+		Awaitility.await().atLeast(100, TimeUnit.MILLISECONDS);
+		assertEquals("I was interrupted", future.get());
+
+		future = svce.submit(task);
+		Awaitility.await().atLeast(100, TimeUnit.MILLISECONDS);
+		future.cancel(true);
+		Awaitility.await().atLeast(100, TimeUnit.MILLISECONDS);
+		assertEquals("I was interrupted", future.get());
+
+	}
+
+}