org.apache.commons/commons-lang3/3.11 : org/apache/commons/lang3/concurrent/BackgroundInitializer.class

BackgroundInitializer

https://commons.apache.org/proper/commons-lang/: Apache Commons Lang, a package of Java utility classes for the classes that are in java.lang's hierarchy, or are considered to be so standard as to justify existence in java.lang. (The Apache Software Foundation)

Apache License, Version 2.0

C. Scott Ananian
Chris Audley
Stephane Bailliez
Michael Becke
Benjamin Bentmann
Ola Berg
Nathan Beyer
Stefan Bodewig
Janek Bogucki
Mike Bowler
Sean Brown
Alexander Day Chaffee
Al Chou
Greg Coladonato
Maarten Coene
Justin Couch
Michael Davey
Norm Deane
Morgan Delagrange
Ringo De Smet
Russel Dittmar
Steve Downey
Matthias Eichel
Christopher Elkins
Chris Feldhacker
Roland Foerther
Pete Gieser
Jason Gritman
Matthew Hawthorne
Michael Heuer
Chas Honton
Chris Hyzer
Paul Jack
Marc Johnson
Shaun Kalley
Tetsuya Kaneuchi
Nissim Karpenstein
Ed Korthof
Holger Krauth
Rafal Krupinski
Rafal Krzewski
David Leppik
Eli Lindsey
Sven Ludwig
Craig R. McClanahan
Rand McNeely
Hendrik Maryns
Dave Meikle
Nikolay Metchev
Kasper Nielsen
Tim O'Brien
Brian S O'Neill
Andrew C. Oliver
Alban Peignier
Moritz Petersen
Dmitri Plotnikov
Neeme Praks
Eric Pugh
Stephen Putman
Travis Reeder
Antony Riley
Valentin Rocher
Scott Sanders
James Sawle
Ralph Schaer
Henning P. Schmiedehausen
Sean Schofield
Robert Scholte
Reuben Sivan
Ville Skytta
David M. Sledge
Michael A. Smith
Jan Sorensen
Glen Stampoultzis
Scott Stanchfield
Jon S. Stevens
Sean C. Sullivan
Ashwin Suresh
Helge Tesgaard
Arun Mammen Thomas
Masato Tezuka
Daniel Trebbien
Jeff Varszegi
Chris Webb
Mario Winterer
Stepan Koltsov
Holger Hoffstatte
Derek C. Ashmore
Sebastien Riou
Allon Mureinik
Adam Hooper
Chris Karcher
Michael Osipov
Thiago Andrade
Jonathan Baker
Mikhail Mazursky
Fabian Lange
Michał Kordas
Felipe Adorno
Adrian Ber
Mark Dacek
Peter Verhas
Jin Xu

Daniel Rall (CollabNet, Inc.)
Stephen Colebourne (SITA ATS Ltd)
Henri Yandell ()
Steven Caswell ()
Robert Burrell Donkin ()
Gary D. Gregory
Fredrik Westermarck ()
James Carman (Carman Consulting, Inc.)
Niall Pemberton
Matt Benson
Joerg Schaible
Oliver Heger
Paul Benedict
Benedikt Ritter
Duncan Jones
Loic Guibert
Rob Tompkins

public abstract class org.apache.commons.lang3.concurrent.BackgroundInitializer<T> implements org.apache.commons.lang3.concurrent.ConcurrentInitializer<T>
  minor version: 0
  major version: 59
  flags: flags: (0x0421) ACC_PUBLIC, ACC_SUPER, ACC_ABSTRACT
  this_class: org.apache.commons.lang3.concurrent.BackgroundInitializer
  super_class: java.lang.Object
{
  private java.util.concurrent.ExecutorService externalExecutor;
    descriptor: Ljava/util/concurrent/ExecutorService;
    flags: (0x0002) ACC_PRIVATE

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

  private java.util.concurrent.Future<T> future;
    descriptor: Ljava/util/concurrent/Future;
    flags: (0x0002) ACC_PRIVATE
    Signature: Ljava/util/concurrent/Future<TT;>;

  protected void <init>();
    descriptor: ()V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.apache.commons.lang3.concurrent.BackgroundInitializer this
         0: .line 101
            aload 0 /* this */
            aconst_null
            invokespecial org.apache.commons.lang3.concurrent.BackgroundInitializer.<init>:(Ljava/util/concurrent/ExecutorService;)V
         1: .line 102
            return
        end local 0 // org.apache.commons.lang3.concurrent.BackgroundInitializer this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lorg/apache/commons/lang3/concurrent/BackgroundInitializer<TT;>;

  protected void <init>(java.util.concurrent.ExecutorService);
    descriptor: (Ljava/util/concurrent/ExecutorService;)V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // org.apache.commons.lang3.concurrent.BackgroundInitializer this
        start local 1 // java.util.concurrent.ExecutorService exec
         0: .line 114
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 115
            aload 0 /* this */
            aload 1 /* exec */
            invokevirtual org.apache.commons.lang3.concurrent.BackgroundInitializer.setExternalExecutor:(Ljava/util/concurrent/ExecutorService;)V
         2: .line 116
            return
        end local 1 // java.util.concurrent.ExecutorService exec
        end local 0 // org.apache.commons.lang3.concurrent.BackgroundInitializer this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lorg/apache/commons/lang3/concurrent/BackgroundInitializer<TT;>;
            0    3     1  exec  Ljava/util/concurrent/ExecutorService;
    MethodParameters:
      Name  Flags
      exec  final

  public final synchronized java.util.concurrent.ExecutorService getExternalExecutor();
    descriptor: ()Ljava/util/concurrent/ExecutorService;
    flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SYNCHRONIZED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.commons.lang3.concurrent.BackgroundInitializer this
         0: .line 124
            aload 0 /* this */
            getfield org.apache.commons.lang3.concurrent.BackgroundInitializer.externalExecutor:Ljava/util/concurrent/ExecutorService;
            areturn
        end local 0 // org.apache.commons.lang3.concurrent.BackgroundInitializer this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/commons/lang3/concurrent/BackgroundInitializer<TT;>;

  public synchronized boolean isStarted();
    descriptor: ()Z
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.commons.lang3.concurrent.BackgroundInitializer this
         0: .line 135
            aload 0 /* this */
            getfield org.apache.commons.lang3.concurrent.BackgroundInitializer.future:Ljava/util/concurrent/Future;
            ifnull 1
            iconst_1
            ireturn
      StackMap locals:
      StackMap stack:
         1: iconst_0
            ireturn
        end local 0 // org.apache.commons.lang3.concurrent.BackgroundInitializer this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lorg/apache/commons/lang3/concurrent/BackgroundInitializer<TT;>;

  public final synchronized void setExternalExecutor(java.util.concurrent.ExecutorService);
    descriptor: (Ljava/util/concurrent/ExecutorService;)V
    flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SYNCHRONIZED
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // org.apache.commons.lang3.concurrent.BackgroundInitializer this
        start local 1 // java.util.concurrent.ExecutorService externalExecutor
         0: .line 154
            aload 0 /* this */
            invokevirtual org.apache.commons.lang3.concurrent.BackgroundInitializer.isStarted:()Z
            ifeq 4
         1: .line 155
            new java.lang.IllegalStateException
            dup
         2: .line 156
            ldc "Cannot set ExecutorService after start()!"
         3: .line 155
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         4: .line 159
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* externalExecutor */
            putfield org.apache.commons.lang3.concurrent.BackgroundInitializer.externalExecutor:Ljava/util/concurrent/ExecutorService;
         5: .line 160
            return
        end local 1 // java.util.concurrent.ExecutorService externalExecutor
        end local 0 // org.apache.commons.lang3.concurrent.BackgroundInitializer this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    6     0              this  Lorg/apache/commons/lang3/concurrent/BackgroundInitializer<TT;>;
            0    6     1  externalExecutor  Ljava/util/concurrent/ExecutorService;
    MethodParameters:
                  Name  Flags
      externalExecutor  final

  public synchronized boolean start();
    descriptor: ()Z
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=4, locals=2, args_size=1
        start local 0 // org.apache.commons.lang3.concurrent.BackgroundInitializer this
         0: .line 174
            aload 0 /* this */
            invokevirtual org.apache.commons.lang3.concurrent.BackgroundInitializer.isStarted:()Z
            ifne 9
         1: .line 179
            aload 0 /* this */
            aload 0 /* this */
            invokevirtual org.apache.commons.lang3.concurrent.BackgroundInitializer.getExternalExecutor:()Ljava/util/concurrent/ExecutorService;
            putfield org.apache.commons.lang3.concurrent.BackgroundInitializer.executor:Ljava/util/concurrent/ExecutorService;
         2: .line 180
            aload 0 /* this */
            getfield org.apache.commons.lang3.concurrent.BackgroundInitializer.executor:Ljava/util/concurrent/ExecutorService;
            ifnonnull 6
         3: .line 181
            aload 0 /* this */
            aload 0 /* this */
            invokevirtual org.apache.commons.lang3.concurrent.BackgroundInitializer.createExecutor:()Ljava/util/concurrent/ExecutorService;
            dup
            astore 1 /* tempExec */
        start local 1 // java.util.concurrent.ExecutorService tempExec
         4: putfield org.apache.commons.lang3.concurrent.BackgroundInitializer.executor:Ljava/util/concurrent/ExecutorService;
         5: .line 182
            goto 7
        end local 1 // java.util.concurrent.ExecutorService tempExec
         6: .line 183
      StackMap locals:
      StackMap stack:
            aconst_null
            astore 1 /* tempExec */
        start local 1 // java.util.concurrent.ExecutorService tempExec
         7: .line 186
      StackMap locals: java.util.concurrent.ExecutorService
      StackMap stack:
            aload 0 /* this */
            aload 0 /* this */
            getfield org.apache.commons.lang3.concurrent.BackgroundInitializer.executor:Ljava/util/concurrent/ExecutorService;
            aload 0 /* this */
            aload 1 /* tempExec */
            invokevirtual org.apache.commons.lang3.concurrent.BackgroundInitializer.createTask:(Ljava/util/concurrent/ExecutorService;)Ljava/util/concurrent/Callable;
            invokeinterface java.util.concurrent.ExecutorService.submit:(Ljava/util/concurrent/Callable;)Ljava/util/concurrent/Future;
            putfield org.apache.commons.lang3.concurrent.BackgroundInitializer.future:Ljava/util/concurrent/Future;
         8: .line 188
            iconst_1
            ireturn
        end local 1 // java.util.concurrent.ExecutorService tempExec
         9: .line 191
      StackMap locals:
      StackMap stack:
            iconst_0
            ireturn
        end local 0 // org.apache.commons.lang3.concurrent.BackgroundInitializer this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   10     0      this  Lorg/apache/commons/lang3/concurrent/BackgroundInitializer<TT;>;
            4    6     1  tempExec  Ljava/util/concurrent/ExecutorService;
            7    9     1  tempExec  Ljava/util/concurrent/ExecutorService;

  public T get();
    descriptor: ()Ljava/lang/Object;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=1
        start local 0 // org.apache.commons.lang3.concurrent.BackgroundInitializer this
         0: .line 211
            aload 0 /* this */
            invokevirtual org.apache.commons.lang3.concurrent.BackgroundInitializer.getFuture:()Ljava/util/concurrent/Future;
            invokeinterface java.util.concurrent.Future.get:()Ljava/lang/Object;
         1: areturn
         2: .line 212
      StackMap locals:
      StackMap stack: java.util.concurrent.ExecutionException
            astore 1 /* execex */
        start local 1 // java.util.concurrent.ExecutionException execex
         3: .line 213
            aload 1 /* execex */
            invokestatic org.apache.commons.lang3.concurrent.ConcurrentUtils.handleCause:(Ljava/util/concurrent/ExecutionException;)V
         4: .line 214
            aconst_null
            areturn
        end local 1 // java.util.concurrent.ExecutionException execex
         5: .line 215
      StackMap locals:
      StackMap stack: java.lang.InterruptedException
            astore 1 /* iex */
        start local 1 // java.lang.InterruptedException iex
         6: .line 217
            invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
            invokevirtual java.lang.Thread.interrupt:()V
         7: .line 218
            new org.apache.commons.lang3.concurrent.ConcurrentException
            dup
            aload 1 /* iex */
            invokespecial org.apache.commons.lang3.concurrent.ConcurrentException.<init>:(Ljava/lang/Throwable;)V
            athrow
        end local 1 // java.lang.InterruptedException iex
        end local 0 // org.apache.commons.lang3.concurrent.BackgroundInitializer this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    8     0    this  Lorg/apache/commons/lang3/concurrent/BackgroundInitializer<TT;>;
            3    5     1  execex  Ljava/util/concurrent/ExecutionException;
            6    8     1     iex  Ljava/lang/InterruptedException;
      Exception table:
        from    to  target  type
           0     1       2  Class java.util.concurrent.ExecutionException
           0     1       5  Class java.lang.InterruptedException
    Exceptions:
      throws org.apache.commons.lang3.concurrent.ConcurrentException
    Signature: ()TT;

  public synchronized java.util.concurrent.Future<T> getFuture();
    descriptor: ()Ljava/util/concurrent/Future;
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // org.apache.commons.lang3.concurrent.BackgroundInitializer this
         0: .line 231
            aload 0 /* this */
            getfield org.apache.commons.lang3.concurrent.BackgroundInitializer.future:Ljava/util/concurrent/Future;
            ifnonnull 2
         1: .line 232
            new java.lang.IllegalStateException
            dup
            ldc "start() must be called first!"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 235
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.commons.lang3.concurrent.BackgroundInitializer.future:Ljava/util/concurrent/Future;
            areturn
        end local 0 // org.apache.commons.lang3.concurrent.BackgroundInitializer this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lorg/apache/commons/lang3/concurrent/BackgroundInitializer<TT;>;
    Signature: ()Ljava/util/concurrent/Future<TT;>;

  protected final synchronized java.util.concurrent.ExecutorService getActiveExecutor();
    descriptor: ()Ljava/util/concurrent/ExecutorService;
    flags: (0x0034) ACC_PROTECTED, ACC_FINAL, ACC_SYNCHRONIZED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.commons.lang3.concurrent.BackgroundInitializer this
         0: .line 248
            aload 0 /* this */
            getfield org.apache.commons.lang3.concurrent.BackgroundInitializer.executor:Ljava/util/concurrent/ExecutorService;
            areturn
        end local 0 // org.apache.commons.lang3.concurrent.BackgroundInitializer this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/commons/lang3/concurrent/BackgroundInitializer<TT;>;

  protected int getTaskCount();
    descriptor: ()I
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.commons.lang3.concurrent.BackgroundInitializer this
         0: .line 263
            iconst_1
            ireturn
        end local 0 // org.apache.commons.lang3.concurrent.BackgroundInitializer this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/commons/lang3/concurrent/BackgroundInitializer<TT;>;

  protected abstract T initialize();
    descriptor: ()Ljava/lang/Object;
    flags: (0x0404) ACC_PROTECTED, ACC_ABSTRACT
    Exceptions:
      throws java.lang.Exception
    Signature: ()TT;

  private java.util.concurrent.Callable<T> createTask(java.util.concurrent.ExecutorService);
    descriptor: (Ljava/util/concurrent/ExecutorService;)Ljava/util/concurrent/Callable;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // org.apache.commons.lang3.concurrent.BackgroundInitializer this
        start local 1 // java.util.concurrent.ExecutorService execDestroy
         0: .line 290
            new org.apache.commons.lang3.concurrent.BackgroundInitializer$InitializationTask
            dup
            aload 0 /* this */
            aload 1 /* execDestroy */
            invokespecial org.apache.commons.lang3.concurrent.BackgroundInitializer$InitializationTask.<init>:(Lorg/apache/commons/lang3/concurrent/BackgroundInitializer;Ljava/util/concurrent/ExecutorService;)V
            areturn
        end local 1 // java.util.concurrent.ExecutorService execDestroy
        end local 0 // org.apache.commons.lang3.concurrent.BackgroundInitializer this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    1     0         this  Lorg/apache/commons/lang3/concurrent/BackgroundInitializer<TT;>;
            0    1     1  execDestroy  Ljava/util/concurrent/ExecutorService;
    Signature: (Ljava/util/concurrent/ExecutorService;)Ljava/util/concurrent/Callable<TT;>;
    MethodParameters:
             Name  Flags
      execDestroy  final

  private java.util.concurrent.ExecutorService createExecutor();
    descriptor: ()Ljava/util/concurrent/ExecutorService;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.commons.lang3.concurrent.BackgroundInitializer this
         0: .line 300
            aload 0 /* this */
            invokevirtual org.apache.commons.lang3.concurrent.BackgroundInitializer.getTaskCount:()I
            invokestatic java.util.concurrent.Executors.newFixedThreadPool:(I)Ljava/util/concurrent/ExecutorService;
            areturn
        end local 0 // org.apache.commons.lang3.concurrent.BackgroundInitializer this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/commons/lang3/concurrent/BackgroundInitializer<TT;>;
}
Signature: <T:Ljava/lang/Object;>Ljava/lang/Object;Lorg/apache/commons/lang3/concurrent/ConcurrentInitializer<TT;>;
SourceFile: "BackgroundInitializer.java"
NestMembers:
  org.apache.commons.lang3.concurrent.BackgroundInitializer$InitializationTask
InnerClasses:
  private InitializationTask = org.apache.commons.lang3.concurrent.BackgroundInitializer$InitializationTask of org.apache.commons.lang3.concurrent.BackgroundInitializer

/

org.apache.commons/ commons-lang3/ 3.11/ org/apache/commons/lang3/concurrent/BackgroundInitializer.class