2 files changed, 0 insertions, 82 deletions
diff --git a/main/src/cgeo/geocaching/concurrent/BlockingThreadPool.java b/main/src/cgeo/geocaching/concurrent/BlockingThreadPool.java
deleted file mode 100644
index a6d7e9b..0000000
--- a/main/src/cgeo/geocaching/concurrent/BlockingThreadPool.java
+++ /dev/null
@@ -1,57 +0,0 @@
-package cgeo.geocaching.concurrent;
-
-
-import java.util.concurrent.ArrayBlockingQueue;
-import java.util.concurrent.BlockingQueue;
-import java.util.concurrent.ThreadFactory;
-import java.util.concurrent.ThreadPoolExecutor;
-import java.util.concurrent.TimeUnit;
-
-/**
- * BlockingThreadPool restricts the amount of parallel threads executing Runnables.
- */
-public class BlockingThreadPool {
-    /** The queue holding the Runnable. **/
-    private BlockingQueue<Runnable> queue = null;
-    /** The Executor. **/
-    private ThreadPoolExecutor executor;
-
-    /**
-     * Creates a ThreadPool with a given maximum of parallel threads running.
-     * Idle threads will be stopped until new threads are added.
-     *
-     * @param poolSize
-     *            Maximum amout of parallel Threads
-     * @param priority
-     *            The Thread priority e.g. Thread.MIN_PRIORITY
-     */
-    public BlockingThreadPool(int poolSize, int priority) {
-        ThreadFactory threadFactory = new PriorityThreadFactory(priority);
-        this.queue = new ArrayBlockingQueue<>(poolSize, true);
-        this.executor = new ThreadPoolExecutor(0, poolSize, 5, TimeUnit.SECONDS, this.queue);
-        this.executor.setThreadFactory(threadFactory);
-    }
-
-    /**
-     * Add a runnable to the pool. This will start the core threads in the underlying
-     * executor and try to add the Runnable to the pool. This method waits until timeout
-     * if no free thread is available.
-     *
-     * @param task
-     *            The Runnable to add to the pool
-     * @param timeout
-     *            The timeout to wait for a free thread
-     * @param unit
-     *            The timeout unit
-     * @return true/false successful added
-     * @throws InterruptedException
-     *             Operation was interrupted
-     */
-    public boolean add(Runnable task, int timeout, TimeUnit unit) throws InterruptedException {
-        this.executor.setCorePoolSize(this.executor.getMaximumPoolSize());
-        this.executor.prestartAllCoreThreads();
-        boolean successfull = this.queue.offer(task, timeout, unit);
-        this.executor.setCorePoolSize(0);
-        return successfull;
-    }
-}
diff --git a/main/src/cgeo/geocaching/concurrent/PriorityThreadFactory.java b/main/src/cgeo/geocaching/concurrent/PriorityThreadFactory.java
deleted file mode 100644
index 0da198b..0000000
--- a/main/src/cgeo/geocaching/concurrent/PriorityThreadFactory.java
+++ /dev/null
@@ -1,25 +0,0 @@
-package cgeo.geocaching.concurrent;
-
-import org.eclipse.jdt.annotation.NonNull;
-
-import java.util.concurrent.ThreadFactory;
-
-/**
- * Helper class for setting Thread priority in ThreadPool.
- */
-public class PriorityThreadFactory implements ThreadFactory {
-    private int priority;
-
-    public PriorityThreadFactory(int priority) {
-        this.priority = priority;
-    }
-
-    @NonNull
-    @Override
-    public Thread newThread(Runnable r) {
-        Thread result = new Thread(r);
-        result.setPriority(this.priority);
-        return result;
-    }
-
-}