Package com.sportradar.livedata.sdk.common.thread

Class SRScheduledThreadPoolExecutor

java.lang.Object
java.util.concurrent.AbstractExecutorService
java.util.concurrent.ThreadPoolExecutor
java.util.concurrent.ScheduledThreadPoolExecutor
com.sportradar.livedata.sdk.common.thread.SRScheduledThreadPoolExecutor
All Implemented Interfaces:
AutoCloseable, Executor, ExecutorService, ScheduledExecutorService
public class SRScheduledThreadPoolExecutor extends ScheduledThreadPoolExecutor
Created with IntelliJ IDEA. User: gso Date: 12/12/13 Time: 15:39 To change this template use File | Settings | File Templates.

  • Constructor Details

    • SRScheduledThreadPoolExecutor

      public SRScheduledThreadPoolExecutor(int corePoolSize)
      Creates a new ScheduledThreadPoolExecutor with the given core pool size.
      Parameters:
      corePoolSize - the number of threads to keep in the pool, even if they are idle, unless allowCoreThreadTimeOut is set
      Throws:
      IllegalArgumentException - if corePoolSize < 0

    • SRScheduledThreadPoolExecutor

      public SRScheduledThreadPoolExecutor(int corePoolSize, RejectedExecutionHandler handler)
      Creates a new ScheduledThreadPoolExecutor with the given initial parameters.
      Parameters:
      corePoolSize - the number of threads to keep in the pool, even if they are idle, unless allowCoreThreadTimeOut is set
      handler - the handler to use when execution is blocked because the thread bounds and queue capacities are reached
      Throws:
      IllegalArgumentException - if corePoolSize < 0
      NullPointerException - if handler is null

    • SRScheduledThreadPoolExecutor

      public SRScheduledThreadPoolExecutor(int corePoolSize, ThreadFactory threadFactory)
      Creates a new ScheduledThreadPoolExecutor with the given initial parameters.
      Parameters:
      corePoolSize - the number of threads to keep in the pool, even if they are idle, unless allowCoreThreadTimeOut is set
      threadFactory - the factory to use when the executor creates a new thread
      Throws:
      IllegalArgumentException - if corePoolSize < 0
      NullPointerException - if threadFactory is null

    • SRScheduledThreadPoolExecutor

      public SRScheduledThreadPoolExecutor(int corePoolSize, ThreadFactory threadFactory, RejectedExecutionHandler handler)
      Creates a new ScheduledThreadPoolExecutor with the given initial parameters.
      Parameters:
      corePoolSize - the number of threads to keep in the pool, even if they are idle, unless allowCoreThreadTimeOut is set
      threadFactory - the factory to use when the executor creates a new thread
      handler - the handler to use when execution is blocked because the thread bounds and queue capacities are reached
      Throws:
      IllegalArgumentException - if corePoolSize < 0
      NullPointerException - if threadFactory or handler is null

  • Method Details

    • afterExecute

      protected void afterExecute(Runnable r, Throwable t)

      Method invoked upon completion of execution of the given Runnable. This method is invoked by the thread that executed the task. If non-null, the Throwable is the uncaught RuntimeException or Error that caused execution to terminate abruptly.

      This implementation does nothing, but may be customized in subclasses. Note: To properly nest multiple overridings, subclasses should generally invoke super.afterExecute at the beginning of this method.

      Note: When actions are enclosed in tasks (such as FutureTask) either explicitly or via methods such as submit, these task objects catch and maintain computational exceptions, and so they do not cause abrupt termination, and the internal exceptions are not passed to this method. If you would like to trap both kinds of failures in this method, you can further probe for such cases, as in this sample subclass that prints either the direct cause or the underlying exception if a task has been aborted: 

       
 class ExtendedExecutor extends ThreadPoolExecutor {
   // ...
   protected void afterExecute(Runnable r, Throwable t) {
     super.afterExecute(r, t);
     if (t == null && r instanceof Future<?>) {
       try {
         Object result = ((Future<?>) r).get();
       } catch (CancellationException ce) {
           t = ce;
       } catch (ExecutionException ee) {
           t = ee.getCause();
       } catch (InterruptedException ie) {
           Thread.currentThread().interrupt(); // ignore/reset
       }
     }
     if (t != null)
       System.out.println(t);
   }
 }
      Overrides:
      afterExecute in class ThreadPoolExecutor
      Parameters:
      r - the runnable that has completed
      t - the exception that caused termination, or null if execution completed normally