ThreadPoolExecutor java example

GeoExecutor.java

import android.os.Process;
import android.util.Log;

import java.util.concurrent.LinkedBlockingDeque;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

/**
 * Created by cutiko on 30-11-17.
 */

public class GeoExecutor extends ThreadPoolExecutor {

    private static final GeoExecutor ourInstance = new GeoExecutor();

    public static GeoExecutor getInstance() {
        return ourInstance;
    }

    private GeoExecutor() {
        super(Runtime.getRuntime().availableProcessors(), Runtime.getRuntime().availableProcessors()*2, 60, TimeUnit.SECONDS, new LinkedBlockingDeque<Runnable>(), new BackgroundThreadFactory());
    }


    private static class BackgroundThreadFactory implements ThreadFactory {
        @Override
        public Thread newThread(Runnable runnable) {
            Thread thread = new Thread(runnable);
            thread.setName("CustomThread" + "GeoExecutor");
            thread.setPriority(Process.THREAD_PRIORITY_BACKGROUND);
            thread.setUncaughtExceptionHandler(new Thread.UncaughtExceptionHandler() {
                @Override
                public void uncaughtException(Thread thread, Throwable ex) {
                    Log.e("THREAD_ERROR", thread.getName() + " encountered an error: " + ex.getMessage());
                }
            });
            return thread;
        }
    }
}