Is there an ExecutorService that uses the current thread?

by

You can use Guava’s MoreExecutors.newDirectExecutorService(), or MoreExecutors.directExecutor() if you don’t need an ExecutorService.

If including Guava is too heavy-weight, you can implement something almost as good:

public final class SameThreadExecutorService extends ThreadPoolExecutor {
  private final CountDownLatch signal = new CountDownLatch(1);

  private SameThreadExecutorService() {
    super(1, 1, 0, TimeUnit.DAYS, new SynchronousQueue<Runnable>(),
        new ThreadPoolExecutor.CallerRunsPolicy());
  }

  @Override public void shutdown() {
    super.shutdown();
    signal.countDown();
  }

  public static ExecutorService getInstance() {
    return SingletonHolder.instance;
  }

  private static class SingletonHolder {
    static ExecutorService instance = createInstance();    
  }

  private static ExecutorService createInstance() {
    final SameThreadExecutorService instance
        = new SameThreadExecutorService();

    // The executor has one worker thread. Give it a Runnable that waits
    // until the executor service is shut down.
    // All other submitted tasks will use the RejectedExecutionHandler
    // which runs tasks using the  caller's thread.
    instance.submit(new Runnable() {
        @Override public void run() {
          boolean interrupted = false;
          try {
            while (true) {
              try {
                instance.signal.await();
                break;
              } catch (InterruptedException e) {
                interrupted = true;
              }
            }
          } finally {
            if (interrupted) {
              Thread.currentThread().interrupt();
            }
          }
        }});
    return Executors.unconfigurableScheduledExecutorService(instance);
  }
}

More Related Contents:

  1. Why must wait() always be in synchronized block
  2. How to share data with two(2) SwingWorker class in Java
  3. ConcurrentModificationException despite using synchronized
  4. Volatile vs Static in Java
  5. Swing – Update Label
  6. How to make ThreadPoolExecutor’s submit() method block if it is saturated?
  7. Why use a ReentrantLock if one can use synchronized(this)?
  8. How do I simulate a buffered peripheral device with SwingWorker?
  9. Is volatile expensive?
  10. How do I call some blocking method with a timeout in Java?
  11. Java Executors: how can I set task priority?
  12. Volatile variable in Java
  13. What is the JVM thread scheduling algorithm?
  14. What is the difference between synchronized on lockObject and using this as the lock?
  15. How do I implement task prioritization using an ExecutorService in Java 5?
  16. Why does Thread.isInterrupted () always return false?
  17. More efficient way for pausing loop wanted
  18. Java Concurrency: CAS vs Locking [closed]
  19. How does `this` reference to an outer class escape through publishing inner class instance?
  20. Java memory model – can someone explain it?
  21. Are non-synchronised static methods thread safe if they don’t modify static class variables?
  22. When do I need to use AtomicBoolean in Java?
  23. Java concurrency: Countdown latch vs Cyclic barrier
  24. Hashmap concurrency issue
  25. Which concurrent Queue implementation should I use in Java?
  26. Java concurrency: is final field (initialized in constructor) thread-safe?
  27. Java: ExecutorService that blocks on submission after a certain queue size [duplicate]
  28. Jboss Java EE container and an ExecutorService
  29. Java: is there no AtomicFloat or AtomicDouble?
  30. Future task of ExecutorService not truly cancelling

Leave a Comment