Package org.elasticsearch.threadpool

Class Scheduler.SafeScheduledThreadPoolExecutor

org.elasticsearch.threadpool.Scheduler.SafeScheduledThreadPoolExecutor
All Implemented Interfaces:
, ,
Enclosing interface:
Scheduler
public static class Scheduler.SafeScheduledThreadPoolExecutor extends
This subclass ensures to properly bubble up Throwable instances of both type Error and Exception thrown in submitted/scheduled tasks to the uncaught exception handler

  • Nested Class Summary

    Nested classes/interfaces inherited from class java.util.concurrent.

    , , ,

  • Constructor Summary

    Constructors
    Constructor
    Description
    SafeScheduledThreadPoolExecutor​(int corePoolSize)
     
    SafeScheduledThreadPoolExecutor​(int corePoolSize,  threadFactory)
     
    SafeScheduledThreadPoolExecutor​(int corePoolSize,  threadFactory,  handler)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
     r,  t)
     

    Methods inherited from class java.util.concurrent.

    , , , , , , , , , , , , , , , , , ,

    Methods inherited from class java.util.concurrent.

    , , , , , , , , , , , , , , , , , , , , , , , , , , , ,

    Methods inherited from class java.util.concurrent.

    , , , , ,

    Methods inherited from class java.lang.

    , , , , , , , ,

    Methods inherited from interface java.util.concurrent.

    , , , , , ,

  • Constructor Details

    • SafeScheduledThreadPoolExecutor

      public SafeScheduledThreadPoolExecutor​(int corePoolSize,  threadFactory,  handler)

    • SafeScheduledThreadPoolExecutor

      public SafeScheduledThreadPoolExecutor​(int corePoolSize,  threadFactory)

    • SafeScheduledThreadPoolExecutor

      public SafeScheduledThreadPoolExecutor​(int corePoolSize)

  • Method Details

    • afterExecute

      protected void afterExecute​( r,  t)
      Overrides:
       in class