https://github.com/spring-projects/spring-framework: Spring Context (Spring IO)
  • Juergen Hoeller 
public class org.springframework.scheduling.concurrent.ConcurrentTaskScheduler extends org.springframework.scheduling.concurrent.ConcurrentTaskExecutor implements org.springframework.scheduling.TaskScheduler
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.springframework.scheduling.concurrent.ConcurrentTaskScheduler
  super_class: org.springframework.scheduling.concurrent.ConcurrentTaskExecutor
{
  private static java.lang.Class<?> managedScheduledExecutorServiceClass;
    descriptor: Ljava/lang/Class;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Signature: Ljava/lang/Class<*>;
    RuntimeVisibleAnnotations: 
      org.springframework.lang.Nullable()

  private java.util.concurrent.ScheduledExecutorService scheduledExecutor;
    descriptor: Ljava/util/concurrent/ScheduledExecutorService;
    flags: (0x0002) ACC_PRIVATE

  private boolean enterpriseConcurrentScheduler;
    descriptor: Z
    flags: (0x0002) ACC_PRIVATE

  private org.springframework.util.ErrorHandler errorHandler;
    descriptor: Lorg/springframework/util/ErrorHandler;
    flags: (0x0002) ACC_PRIVATE
    RuntimeVisibleAnnotations: 
      org.springframework.lang.Nullable()

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=2, locals=0, args_size=0
         0: .line 74
            ldc "javax.enterprise.concurrent.ManagedScheduledExecutorService"
         1: .line 75
            ldc Lorg/springframework/scheduling/concurrent/ConcurrentTaskScheduler;
            invokevirtual java.lang.Class.getClassLoader:()Ljava/lang/ClassLoader;
         2: .line 73
            invokestatic org.springframework.util.ClassUtils.forName:(Ljava/lang/String;Ljava/lang/ClassLoader;)Ljava/lang/Class;
            putstatic org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.managedScheduledExecutorServiceClass:Ljava/lang/Class;
         3: .line 76
            goto 6
         4: .line 77
      StackMap locals:
      StackMap stack: java.lang.ClassNotFoundException
            pop
         5: .line 79
            aconst_null
            putstatic org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.managedScheduledExecutorServiceClass:Ljava/lang/Class;
         6: .line 81
      StackMap locals:
      StackMap stack:
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature
      Exception table:
        from    to  target  type
           0     3       4  Class java.lang.ClassNotFoundException

  public void <init>();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // org.springframework.scheduling.concurrent.ConcurrentTaskScheduler this
         0: .line 98
            aload 0 /* this */
            invokespecial org.springframework.scheduling.concurrent.ConcurrentTaskExecutor.<init>:()V
         1: .line 86
            aload 0 /* this */
            iconst_0
            putfield org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.enterpriseConcurrentScheduler:Z
         2: .line 99
            aload 0 /* this */
            aload 0 /* this */
            aconst_null
            invokevirtual org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.initScheduledExecutor:(Ljava/util/concurrent/ScheduledExecutorService;)Ljava/util/concurrent/ScheduledExecutorService;
            putfield org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.scheduledExecutor:Ljava/util/concurrent/ScheduledExecutorService;
         3: .line 100
            return
        end local 0 // org.springframework.scheduling.concurrent.ConcurrentTaskScheduler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lorg/springframework/scheduling/concurrent/ConcurrentTaskScheduler;

  public void <init>(java.util.concurrent.ScheduledExecutorService);
    descriptor: (Ljava/util/concurrent/ScheduledExecutorService;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // org.springframework.scheduling.concurrent.ConcurrentTaskScheduler this
        start local 1 // java.util.concurrent.ScheduledExecutorService scheduledExecutor
         0: .line 113
            aload 0 /* this */
            aload 1 /* scheduledExecutor */
            invokespecial org.springframework.scheduling.concurrent.ConcurrentTaskExecutor.<init>:(Ljava/util/concurrent/Executor;)V
         1: .line 86
            aload 0 /* this */
            iconst_0
            putfield org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.enterpriseConcurrentScheduler:Z
         2: .line 114
            aload 0 /* this */
            aload 0 /* this */
            aload 1 /* scheduledExecutor */
            invokevirtual org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.initScheduledExecutor:(Ljava/util/concurrent/ScheduledExecutorService;)Ljava/util/concurrent/ScheduledExecutorService;
            putfield org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.scheduledExecutor:Ljava/util/concurrent/ScheduledExecutorService;
         3: .line 115
            return
        end local 1 // java.util.concurrent.ScheduledExecutorService scheduledExecutor
        end local 0 // org.springframework.scheduling.concurrent.ConcurrentTaskScheduler this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0    4     0               this  Lorg/springframework/scheduling/concurrent/ConcurrentTaskScheduler;
            0    4     1  scheduledExecutor  Ljava/util/concurrent/ScheduledExecutorService;
    MethodParameters:
                   Name  Flags
      scheduledExecutor  

  public void <init>(java.util.concurrent.Executor, java.util.concurrent.ScheduledExecutorService);
    descriptor: (Ljava/util/concurrent/Executor;Ljava/util/concurrent/ScheduledExecutorService;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // org.springframework.scheduling.concurrent.ConcurrentTaskScheduler this
        start local 1 // java.util.concurrent.Executor concurrentExecutor
        start local 2 // java.util.concurrent.ScheduledExecutorService scheduledExecutor
         0: .line 129
            aload 0 /* this */
            aload 1 /* concurrentExecutor */
            invokespecial org.springframework.scheduling.concurrent.ConcurrentTaskExecutor.<init>:(Ljava/util/concurrent/Executor;)V
         1: .line 86
            aload 0 /* this */
            iconst_0
            putfield org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.enterpriseConcurrentScheduler:Z
         2: .line 130
            aload 0 /* this */
            aload 0 /* this */
            aload 2 /* scheduledExecutor */
            invokevirtual org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.initScheduledExecutor:(Ljava/util/concurrent/ScheduledExecutorService;)Ljava/util/concurrent/ScheduledExecutorService;
            putfield org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.scheduledExecutor:Ljava/util/concurrent/ScheduledExecutorService;
         3: .line 131
            return
        end local 2 // java.util.concurrent.ScheduledExecutorService scheduledExecutor
        end local 1 // java.util.concurrent.Executor concurrentExecutor
        end local 0 // org.springframework.scheduling.concurrent.ConcurrentTaskScheduler this
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0    4     0                this  Lorg/springframework/scheduling/concurrent/ConcurrentTaskScheduler;
            0    4     1  concurrentExecutor  Ljava/util/concurrent/Executor;
            0    4     2   scheduledExecutor  Ljava/util/concurrent/ScheduledExecutorService;
    MethodParameters:
                    Name  Flags
      concurrentExecutor  
      scheduledExecutor   

  private java.util.concurrent.ScheduledExecutorService initScheduledExecutor(java.util.concurrent.ScheduledExecutorService);
    descriptor: (Ljava/util/concurrent/ScheduledExecutorService;)Ljava/util/concurrent/ScheduledExecutorService;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // org.springframework.scheduling.concurrent.ConcurrentTaskScheduler this
        start local 1 // java.util.concurrent.ScheduledExecutorService scheduledExecutor
         0: .line 135
            aload 1 /* scheduledExecutor */
            ifnull 7
         1: .line 136
            aload 0 /* this */
            aload 1 /* scheduledExecutor */
            putfield org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.scheduledExecutor:Ljava/util/concurrent/ScheduledExecutorService;
         2: .line 137
            aload 0 /* this */
            getstatic org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.managedScheduledExecutorServiceClass:Ljava/lang/Class;
            ifnull 4
         3: .line 138
            getstatic org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.managedScheduledExecutorServiceClass:Ljava/lang/Class;
            aload 1 /* scheduledExecutor */
            invokevirtual java.lang.Class.isInstance:(Ljava/lang/Object;)Z
            ifeq 4
            iconst_1
            goto 5
      StackMap locals:
      StackMap stack: org.springframework.scheduling.concurrent.ConcurrentTaskScheduler
         4: iconst_0
         5: .line 137
      StackMap locals: org.springframework.scheduling.concurrent.ConcurrentTaskScheduler java.util.concurrent.ScheduledExecutorService
      StackMap stack: org.springframework.scheduling.concurrent.ConcurrentTaskScheduler int
            putfield org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.enterpriseConcurrentScheduler:Z
         6: .line 139
            goto 9
         7: .line 141
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokestatic java.util.concurrent.Executors.newSingleThreadScheduledExecutor:()Ljava/util/concurrent/ScheduledExecutorService;
            putfield org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.scheduledExecutor:Ljava/util/concurrent/ScheduledExecutorService;
         8: .line 142
            aload 0 /* this */
            iconst_0
            putfield org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.enterpriseConcurrentScheduler:Z
         9: .line 144
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.scheduledExecutor:Ljava/util/concurrent/ScheduledExecutorService;
            areturn
        end local 1 // java.util.concurrent.ScheduledExecutorService scheduledExecutor
        end local 0 // org.springframework.scheduling.concurrent.ConcurrentTaskScheduler this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0   10     0               this  Lorg/springframework/scheduling/concurrent/ConcurrentTaskScheduler;
            0   10     1  scheduledExecutor  Ljava/util/concurrent/ScheduledExecutorService;
    RuntimeVisibleParameterAnnotations: 
      0:
        org.springframework.lang.Nullable()
    MethodParameters:
                   Name  Flags
      scheduledExecutor  

  public void setScheduledExecutor(java.util.concurrent.ScheduledExecutorService);
    descriptor: (Ljava/util/concurrent/ScheduledExecutorService;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // org.springframework.scheduling.concurrent.ConcurrentTaskScheduler this
        start local 1 // java.util.concurrent.ScheduledExecutorService scheduledExecutor
         0: .line 159
            aload 0 /* this */
            aload 1 /* scheduledExecutor */
            invokevirtual org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.initScheduledExecutor:(Ljava/util/concurrent/ScheduledExecutorService;)Ljava/util/concurrent/ScheduledExecutorService;
            pop
         1: .line 160
            return
        end local 1 // java.util.concurrent.ScheduledExecutorService scheduledExecutor
        end local 0 // org.springframework.scheduling.concurrent.ConcurrentTaskScheduler this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0    2     0               this  Lorg/springframework/scheduling/concurrent/ConcurrentTaskScheduler;
            0    2     1  scheduledExecutor  Ljava/util/concurrent/ScheduledExecutorService;
    RuntimeVisibleParameterAnnotations: 
      0:
        org.springframework.lang.Nullable()
    MethodParameters:
                   Name  Flags
      scheduledExecutor  

  public void setErrorHandler(org.springframework.util.ErrorHandler);
    descriptor: (Lorg/springframework/util/ErrorHandler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // org.springframework.scheduling.concurrent.ConcurrentTaskScheduler this
        start local 1 // org.springframework.util.ErrorHandler errorHandler
         0: .line 166
            aload 1 /* errorHandler */
            ldc "ErrorHandler must not be null"
            invokestatic org.springframework.util.Assert.notNull:(Ljava/lang/Object;Ljava/lang/String;)V
         1: .line 167
            aload 0 /* this */
            aload 1 /* errorHandler */
            putfield org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.errorHandler:Lorg/springframework/util/ErrorHandler;
         2: .line 168
            return
        end local 1 // org.springframework.util.ErrorHandler errorHandler
        end local 0 // org.springframework.scheduling.concurrent.ConcurrentTaskScheduler this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    3     0          this  Lorg/springframework/scheduling/concurrent/ConcurrentTaskScheduler;
            0    3     1  errorHandler  Lorg/springframework/util/ErrorHandler;
    MethodParameters:
              Name  Flags
      errorHandler  

  public java.util.concurrent.ScheduledFuture<?> schedule(java.lang.Runnable, org.springframework.scheduling.Trigger);
    descriptor: (Ljava/lang/Runnable;Lorg/springframework/scheduling/Trigger;)Ljava/util/concurrent/ScheduledFuture;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=4, args_size=3
        start local 0 // org.springframework.scheduling.concurrent.ConcurrentTaskScheduler this
        start local 1 // java.lang.Runnable task
        start local 2 // org.springframework.scheduling.Trigger trigger
         0: .line 175
            aload 0 /* this */
            getfield org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.enterpriseConcurrentScheduler:Z
            ifeq 3
         1: .line 176
            new org.springframework.scheduling.concurrent.ConcurrentTaskScheduler$EnterpriseConcurrentTriggerScheduler
            dup
            aload 0 /* this */
            invokespecial org.springframework.scheduling.concurrent.ConcurrentTaskScheduler$EnterpriseConcurrentTriggerScheduler.<init>:(Lorg/springframework/scheduling/concurrent/ConcurrentTaskScheduler;)V
            aload 0 /* this */
            aload 1 /* task */
            iconst_1
            invokevirtual org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.decorateTask:(Ljava/lang/Runnable;Z)Ljava/lang/Runnable;
            aload 2 /* trigger */
            invokevirtual org.springframework.scheduling.concurrent.ConcurrentTaskScheduler$EnterpriseConcurrentTriggerScheduler.schedule:(Ljava/lang/Runnable;Lorg/springframework/scheduling/Trigger;)Ljava/util/concurrent/ScheduledFuture;
         2: areturn
         3: .line 180
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.errorHandler:Lorg/springframework/util/ErrorHandler;
            ifnull 4
            aload 0 /* this */
            getfield org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.errorHandler:Lorg/springframework/util/ErrorHandler;
            goto 5
      StackMap locals:
      StackMap stack:
         4: iconst_1
            invokestatic org.springframework.scheduling.support.TaskUtils.getDefaultErrorHandler:(Z)Lorg/springframework/util/ErrorHandler;
         5: .line 179
      StackMap locals:
      StackMap stack: org.springframework.util.ErrorHandler
            astore 3 /* errorHandler */
        start local 3 // org.springframework.util.ErrorHandler errorHandler
         6: .line 181
            new org.springframework.scheduling.concurrent.ReschedulingRunnable
            dup
            aload 1 /* task */
            aload 2 /* trigger */
            aload 0 /* this */
            getfield org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.scheduledExecutor:Ljava/util/concurrent/ScheduledExecutorService;
            aload 3 /* errorHandler */
            invokespecial org.springframework.scheduling.concurrent.ReschedulingRunnable.<init>:(Ljava/lang/Runnable;Lorg/springframework/scheduling/Trigger;Ljava/util/concurrent/ScheduledExecutorService;Lorg/springframework/util/ErrorHandler;)V
            invokevirtual org.springframework.scheduling.concurrent.ReschedulingRunnable.schedule:()Ljava/util/concurrent/ScheduledFuture;
         7: areturn
        end local 3 // org.springframework.util.ErrorHandler errorHandler
         8: .line 184
      StackMap locals:
      StackMap stack: java.util.concurrent.RejectedExecutionException
            astore 3 /* ex */
        start local 3 // java.util.concurrent.RejectedExecutionException ex
         9: .line 185
            new org.springframework.core.task.TaskRejectedException
            dup
            new java.lang.StringBuilder
            dup
            ldc "Executor ["
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* this */
            getfield org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.scheduledExecutor:Ljava/util/concurrent/ScheduledExecutorService;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            ldc "] did not accept task: "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 1 /* task */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            aload 3 /* ex */
            invokespecial org.springframework.core.task.TaskRejectedException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
            athrow
        end local 3 // java.util.concurrent.RejectedExecutionException ex
        end local 2 // org.springframework.scheduling.Trigger trigger
        end local 1 // java.lang.Runnable task
        end local 0 // org.springframework.scheduling.concurrent.ConcurrentTaskScheduler this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0   10     0          this  Lorg/springframework/scheduling/concurrent/ConcurrentTaskScheduler;
            0   10     1          task  Ljava/lang/Runnable;
            0   10     2       trigger  Lorg/springframework/scheduling/Trigger;
            6    8     3  errorHandler  Lorg/springframework/util/ErrorHandler;
            9   10     3            ex  Ljava/util/concurrent/RejectedExecutionException;
      Exception table:
        from    to  target  type
           0     2       8  Class java.util.concurrent.RejectedExecutionException
           3     7       8  Class java.util.concurrent.RejectedExecutionException
    Signature: (Ljava/lang/Runnable;Lorg/springframework/scheduling/Trigger;)Ljava/util/concurrent/ScheduledFuture<*>;
    RuntimeVisibleAnnotations: 
      org.springframework.lang.Nullable()
    MethodParameters:
         Name  Flags
      task     
      trigger  

  public java.util.concurrent.ScheduledFuture<?> schedule(java.lang.Runnable, java.util.Date);
    descriptor: (Ljava/lang/Runnable;Ljava/util/Date;)Ljava/util/concurrent/ScheduledFuture;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=6, args_size=3
        start local 0 // org.springframework.scheduling.concurrent.ConcurrentTaskScheduler this
        start local 1 // java.lang.Runnable task
        start local 2 // java.util.Date startTime
         0: .line 191
            aload 2 /* startTime */
            invokevirtual java.util.Date.getTime:()J
            invokestatic java.lang.System.currentTimeMillis:()J
            lsub
            lstore 3 /* initialDelay */
        start local 3 // long initialDelay
         1: .line 193
            aload 0 /* this */
            getfield org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.scheduledExecutor:Ljava/util/concurrent/ScheduledExecutorService;
            aload 0 /* this */
            aload 1 /* task */
            iconst_0
            invokevirtual org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.decorateTask:(Ljava/lang/Runnable;Z)Ljava/lang/Runnable;
            lload 3 /* initialDelay */
            getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
            invokeinterface java.util.concurrent.ScheduledExecutorService.schedule:(Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;
         2: areturn
         3: .line 195
      StackMap locals: org.springframework.scheduling.concurrent.ConcurrentTaskScheduler java.lang.Runnable java.util.Date long
      StackMap stack: java.util.concurrent.RejectedExecutionException
            astore 5 /* ex */
        start local 5 // java.util.concurrent.RejectedExecutionException ex
         4: .line 196
            new org.springframework.core.task.TaskRejectedException
            dup
            new java.lang.StringBuilder
            dup
            ldc "Executor ["
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* this */
            getfield org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.scheduledExecutor:Ljava/util/concurrent/ScheduledExecutorService;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            ldc "] did not accept task: "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 1 /* task */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            aload 5 /* ex */
            invokespecial org.springframework.core.task.TaskRejectedException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
            athrow
        end local 5 // java.util.concurrent.RejectedExecutionException ex
        end local 3 // long initialDelay
        end local 2 // java.util.Date startTime
        end local 1 // java.lang.Runnable task
        end local 0 // org.springframework.scheduling.concurrent.ConcurrentTaskScheduler this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    5     0          this  Lorg/springframework/scheduling/concurrent/ConcurrentTaskScheduler;
            0    5     1          task  Ljava/lang/Runnable;
            0    5     2     startTime  Ljava/util/Date;
            1    5     3  initialDelay  J
            4    5     5            ex  Ljava/util/concurrent/RejectedExecutionException;
      Exception table:
        from    to  target  type
           1     2       3  Class java.util.concurrent.RejectedExecutionException
    Signature: (Ljava/lang/Runnable;Ljava/util/Date;)Ljava/util/concurrent/ScheduledFuture<*>;
    MethodParameters:
           Name  Flags
      task       
      startTime  

  public java.util.concurrent.ScheduledFuture<?> scheduleAtFixedRate(java.lang.Runnable, java.util.Date, long);
    descriptor: (Ljava/lang/Runnable;Ljava/util/Date;J)Ljava/util/concurrent/ScheduledFuture;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=8, args_size=4
        start local 0 // org.springframework.scheduling.concurrent.ConcurrentTaskScheduler this
        start local 1 // java.lang.Runnable task
        start local 2 // java.util.Date startTime
        start local 3 // long period
         0: .line 202
            aload 2 /* startTime */
            invokevirtual java.util.Date.getTime:()J
            invokestatic java.lang.System.currentTimeMillis:()J
            lsub
            lstore 5 /* initialDelay */
        start local 5 // long initialDelay
         1: .line 204
            aload 0 /* this */
            getfield org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.scheduledExecutor:Ljava/util/concurrent/ScheduledExecutorService;
            aload 0 /* this */
            aload 1 /* task */
            iconst_1
            invokevirtual org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.decorateTask:(Ljava/lang/Runnable;Z)Ljava/lang/Runnable;
            lload 5 /* initialDelay */
            lload 3 /* period */
            getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
            invokeinterface java.util.concurrent.ScheduledExecutorService.scheduleAtFixedRate:(Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;
         2: areturn
         3: .line 206
      StackMap locals: org.springframework.scheduling.concurrent.ConcurrentTaskScheduler java.lang.Runnable java.util.Date long long
      StackMap stack: java.util.concurrent.RejectedExecutionException
            astore 7 /* ex */
        start local 7 // java.util.concurrent.RejectedExecutionException ex
         4: .line 207
            new org.springframework.core.task.TaskRejectedException
            dup
            new java.lang.StringBuilder
            dup
            ldc "Executor ["
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* this */
            getfield org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.scheduledExecutor:Ljava/util/concurrent/ScheduledExecutorService;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            ldc "] did not accept task: "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 1 /* task */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            aload 7 /* ex */
            invokespecial org.springframework.core.task.TaskRejectedException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
            athrow
        end local 7 // java.util.concurrent.RejectedExecutionException ex
        end local 5 // long initialDelay
        end local 3 // long period
        end local 2 // java.util.Date startTime
        end local 1 // java.lang.Runnable task
        end local 0 // org.springframework.scheduling.concurrent.ConcurrentTaskScheduler this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    5     0          this  Lorg/springframework/scheduling/concurrent/ConcurrentTaskScheduler;
            0    5     1          task  Ljava/lang/Runnable;
            0    5     2     startTime  Ljava/util/Date;
            0    5     3        period  J
            1    5     5  initialDelay  J
            4    5     7            ex  Ljava/util/concurrent/RejectedExecutionException;
      Exception table:
        from    to  target  type
           1     2       3  Class java.util.concurrent.RejectedExecutionException
    Signature: (Ljava/lang/Runnable;Ljava/util/Date;J)Ljava/util/concurrent/ScheduledFuture<*>;
    MethodParameters:
           Name  Flags
      task       
      startTime  
      period     

  public java.util.concurrent.ScheduledFuture<?> scheduleAtFixedRate(java.lang.Runnable, long);
    descriptor: (Ljava/lang/Runnable;J)Ljava/util/concurrent/ScheduledFuture;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=5, args_size=3
        start local 0 // org.springframework.scheduling.concurrent.ConcurrentTaskScheduler this
        start local 1 // java.lang.Runnable task
        start local 2 // long period
         0: .line 214
            aload 0 /* this */
            getfield org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.scheduledExecutor:Ljava/util/concurrent/ScheduledExecutorService;
            aload 0 /* this */
            aload 1 /* task */
            iconst_1
            invokevirtual org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.decorateTask:(Ljava/lang/Runnable;Z)Ljava/lang/Runnable;
            lconst_0
            lload 2 /* period */
            getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
            invokeinterface java.util.concurrent.ScheduledExecutorService.scheduleAtFixedRate:(Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;
         1: areturn
         2: .line 216
      StackMap locals:
      StackMap stack: java.util.concurrent.RejectedExecutionException
            astore 4 /* ex */
        start local 4 // java.util.concurrent.RejectedExecutionException ex
         3: .line 217
            new org.springframework.core.task.TaskRejectedException
            dup
            new java.lang.StringBuilder
            dup
            ldc "Executor ["
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* this */
            getfield org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.scheduledExecutor:Ljava/util/concurrent/ScheduledExecutorService;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            ldc "] did not accept task: "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 1 /* task */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            aload 4 /* ex */
            invokespecial org.springframework.core.task.TaskRejectedException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
            athrow
        end local 4 // java.util.concurrent.RejectedExecutionException ex
        end local 2 // long period
        end local 1 // java.lang.Runnable task
        end local 0 // org.springframework.scheduling.concurrent.ConcurrentTaskScheduler this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    4     0    this  Lorg/springframework/scheduling/concurrent/ConcurrentTaskScheduler;
            0    4     1    task  Ljava/lang/Runnable;
            0    4     2  period  J
            3    4     4      ex  Ljava/util/concurrent/RejectedExecutionException;
      Exception table:
        from    to  target  type
           0     1       2  Class java.util.concurrent.RejectedExecutionException
    Signature: (Ljava/lang/Runnable;J)Ljava/util/concurrent/ScheduledFuture<*>;
    MethodParameters:
        Name  Flags
      task    
      period  

  public java.util.concurrent.ScheduledFuture<?> scheduleWithFixedDelay(java.lang.Runnable, java.util.Date, long);
    descriptor: (Ljava/lang/Runnable;Ljava/util/Date;J)Ljava/util/concurrent/ScheduledFuture;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=8, args_size=4
        start local 0 // org.springframework.scheduling.concurrent.ConcurrentTaskScheduler this
        start local 1 // java.lang.Runnable task
        start local 2 // java.util.Date startTime
        start local 3 // long delay
         0: .line 223
            aload 2 /* startTime */
            invokevirtual java.util.Date.getTime:()J
            invokestatic java.lang.System.currentTimeMillis:()J
            lsub
            lstore 5 /* initialDelay */
        start local 5 // long initialDelay
         1: .line 225
            aload 0 /* this */
            getfield org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.scheduledExecutor:Ljava/util/concurrent/ScheduledExecutorService;
            aload 0 /* this */
            aload 1 /* task */
            iconst_1
            invokevirtual org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.decorateTask:(Ljava/lang/Runnable;Z)Ljava/lang/Runnable;
            lload 5 /* initialDelay */
            lload 3 /* delay */
            getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
            invokeinterface java.util.concurrent.ScheduledExecutorService.scheduleWithFixedDelay:(Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;
         2: areturn
         3: .line 227
      StackMap locals: org.springframework.scheduling.concurrent.ConcurrentTaskScheduler java.lang.Runnable java.util.Date long long
      StackMap stack: java.util.concurrent.RejectedExecutionException
            astore 7 /* ex */
        start local 7 // java.util.concurrent.RejectedExecutionException ex
         4: .line 228
            new org.springframework.core.task.TaskRejectedException
            dup
            new java.lang.StringBuilder
            dup
            ldc "Executor ["
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* this */
            getfield org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.scheduledExecutor:Ljava/util/concurrent/ScheduledExecutorService;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            ldc "] did not accept task: "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 1 /* task */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            aload 7 /* ex */
            invokespecial org.springframework.core.task.TaskRejectedException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
            athrow
        end local 7 // java.util.concurrent.RejectedExecutionException ex
        end local 5 // long initialDelay
        end local 3 // long delay
        end local 2 // java.util.Date startTime
        end local 1 // java.lang.Runnable task
        end local 0 // org.springframework.scheduling.concurrent.ConcurrentTaskScheduler this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    5     0          this  Lorg/springframework/scheduling/concurrent/ConcurrentTaskScheduler;
            0    5     1          task  Ljava/lang/Runnable;
            0    5     2     startTime  Ljava/util/Date;
            0    5     3         delay  J
            1    5     5  initialDelay  J
            4    5     7            ex  Ljava/util/concurrent/RejectedExecutionException;
      Exception table:
        from    to  target  type
           1     2       3  Class java.util.concurrent.RejectedExecutionException
    Signature: (Ljava/lang/Runnable;Ljava/util/Date;J)Ljava/util/concurrent/ScheduledFuture<*>;
    MethodParameters:
           Name  Flags
      task       
      startTime  
      delay      

  public java.util.concurrent.ScheduledFuture<?> scheduleWithFixedDelay(java.lang.Runnable, long);
    descriptor: (Ljava/lang/Runnable;J)Ljava/util/concurrent/ScheduledFuture;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=5, args_size=3
        start local 0 // org.springframework.scheduling.concurrent.ConcurrentTaskScheduler this
        start local 1 // java.lang.Runnable task
        start local 2 // long delay
         0: .line 235
            aload 0 /* this */
            getfield org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.scheduledExecutor:Ljava/util/concurrent/ScheduledExecutorService;
            aload 0 /* this */
            aload 1 /* task */
            iconst_1
            invokevirtual org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.decorateTask:(Ljava/lang/Runnable;Z)Ljava/lang/Runnable;
            lconst_0
            lload 2 /* delay */
            getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
            invokeinterface java.util.concurrent.ScheduledExecutorService.scheduleWithFixedDelay:(Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;
         1: areturn
         2: .line 237
      StackMap locals:
      StackMap stack: java.util.concurrent.RejectedExecutionException
            astore 4 /* ex */
        start local 4 // java.util.concurrent.RejectedExecutionException ex
         3: .line 238
            new org.springframework.core.task.TaskRejectedException
            dup
            new java.lang.StringBuilder
            dup
            ldc "Executor ["
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* this */
            getfield org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.scheduledExecutor:Ljava/util/concurrent/ScheduledExecutorService;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            ldc "] did not accept task: "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 1 /* task */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            aload 4 /* ex */
            invokespecial org.springframework.core.task.TaskRejectedException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
            athrow
        end local 4 // java.util.concurrent.RejectedExecutionException ex
        end local 2 // long delay
        end local 1 // java.lang.Runnable task
        end local 0 // org.springframework.scheduling.concurrent.ConcurrentTaskScheduler this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    4     0   this  Lorg/springframework/scheduling/concurrent/ConcurrentTaskScheduler;
            0    4     1   task  Ljava/lang/Runnable;
            0    4     2  delay  J
            3    4     4     ex  Ljava/util/concurrent/RejectedExecutionException;
      Exception table:
        from    to  target  type
           0     1       2  Class java.util.concurrent.RejectedExecutionException
    Signature: (Ljava/lang/Runnable;J)Ljava/util/concurrent/ScheduledFuture<*>;
    MethodParameters:
       Name  Flags
      task   
      delay  

  private java.lang.Runnable decorateTask(java.lang.Runnable, boolean);
    descriptor: (Ljava/lang/Runnable;Z)Ljava/lang/Runnable;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=4, args_size=3
        start local 0 // org.springframework.scheduling.concurrent.ConcurrentTaskScheduler this
        start local 1 // java.lang.Runnable task
        start local 2 // boolean isRepeatingTask
         0: .line 243
            aload 1 /* task */
            aload 0 /* this */
            getfield org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.errorHandler:Lorg/springframework/util/ErrorHandler;
            iload 2 /* isRepeatingTask */
            invokestatic org.springframework.scheduling.support.TaskUtils.decorateTaskWithErrorHandler:(Ljava/lang/Runnable;Lorg/springframework/util/ErrorHandler;Z)Lorg/springframework/scheduling/support/DelegatingErrorHandlingRunnable;
            astore 3 /* result */
        start local 3 // java.lang.Runnable result
         1: .line 244
            aload 0 /* this */
            getfield org.springframework.scheduling.concurrent.ConcurrentTaskScheduler.enterpriseConcurrentScheduler:Z
            ifeq 3
         2: .line 245
            aload 3 /* result */
            aload 1 /* task */
            invokevirtual java.lang.Object.toString:()Ljava/lang/String;
            invokestatic org.springframework.scheduling.concurrent.ConcurrentTaskExecutor$ManagedTaskBuilder.buildManagedTask:(Ljava/lang/Runnable;Ljava/lang/String;)Ljava/lang/Runnable;
            astore 3 /* result */
         3: .line 247
      StackMap locals: java.lang.Runnable
      StackMap stack:
            aload 3 /* result */
            areturn
        end local 3 // java.lang.Runnable result
        end local 2 // boolean isRepeatingTask
        end local 1 // java.lang.Runnable task
        end local 0 // org.springframework.scheduling.concurrent.ConcurrentTaskScheduler this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    4     0             this  Lorg/springframework/scheduling/concurrent/ConcurrentTaskScheduler;
            0    4     1             task  Ljava/lang/Runnable;
            0    4     2  isRepeatingTask  Z
            1    4     3           result  Ljava/lang/Runnable;
    MethodParameters:
                 Name  Flags
      task             
      isRepeatingTask  
}
SourceFile: "ConcurrentTaskScheduler.java"
NestMembers:
  org.springframework.scheduling.concurrent.ConcurrentTaskScheduler$EnterpriseConcurrentTriggerScheduler  org.springframework.scheduling.concurrent.ConcurrentTaskScheduler$EnterpriseConcurrentTriggerScheduler$1
InnerClasses:
  protected ManagedTaskBuilder = org.springframework.scheduling.concurrent.ConcurrentTaskExecutor$ManagedTaskBuilder of org.springframework.scheduling.concurrent.ConcurrentTaskExecutor
  private EnterpriseConcurrentTriggerScheduler = org.springframework.scheduling.concurrent.ConcurrentTaskScheduler$EnterpriseConcurrentTriggerScheduler of org.springframework.scheduling.concurrent.ConcurrentTaskScheduler