public final class org.eclipse.collections.impl.parallel.ParallelIterate
minor version: 0
major version: 59
flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
this_class: org.eclipse.collections.impl.parallel.ParallelIterate
super_class: java.lang.Object
{
static final int DEFAULT_MIN_FORK_SIZE;
descriptor: I
flags: (0x0018) ACC_STATIC, ACC_FINAL
ConstantValue: 10000
static final int AVAILABLE_PROCESSORS;
descriptor: I
flags: (0x0018) ACC_STATIC, ACC_FINAL
static final int TASK_RATIO;
descriptor: I
flags: (0x0018) ACC_STATIC, ACC_FINAL
ConstantValue: 2
static final int DEFAULT_PARALLEL_TASK_COUNT;
descriptor: I
flags: (0x0018) ACC_STATIC, ACC_FINAL
static final java.util.concurrent.ExecutorService EXECUTOR_SERVICE;
descriptor: Ljava/util/concurrent/ExecutorService;
flags: (0x0018) ACC_STATIC, ACC_FINAL
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: invokestatic java.lang.Runtime.getRuntime:()Ljava/lang/Runtime;
invokevirtual java.lang.Runtime.availableProcessors:()I
putstatic org.eclipse.collections.impl.parallel.ParallelIterate.AVAILABLE_PROCESSORS:I
1: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.getDefaultTaskCount:()I
putstatic org.eclipse.collections.impl.parallel.ParallelIterate.DEFAULT_PARALLEL_TASK_COUNT:I
2: ldc Lorg/eclipse/collections/impl/parallel/ParallelIterate;
invokevirtual java.lang.Class.getSimpleName:()Ljava/lang/String;
iconst_1
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.newPooledExecutor:(Ljava/lang/String;Z)Ljava/util/concurrent/ExecutorService;
putstatic org.eclipse.collections.impl.parallel.ParallelIterate.EXECUTOR_SERVICE:Ljava/util/concurrent/ExecutorService;
return
LocalVariableTable:
Start End Slot Name Signature
private void <init>();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: new java.lang.AssertionError
dup
ldc "Suppress default constructor for noninstantiability"
invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/eclipse/collections/impl/parallel/ParallelIterate;
static boolean isExecutorShutdown();
descriptor: ()Z
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: getstatic org.eclipse.collections.impl.parallel.ParallelIterate.EXECUTOR_SERVICE:Ljava/util/concurrent/ExecutorService;
invokeinterface java.util.concurrent.ExecutorService.isShutdown:()Z
ireturn
LocalVariableTable:
Start End Slot Name Signature
static void shutdownExecutor();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: getstatic org.eclipse.collections.impl.parallel.ParallelIterate.EXECUTOR_SERVICE:Ljava/util/concurrent/ExecutorService;
invokeinterface java.util.concurrent.ExecutorService.shutdown:()V
1: return
LocalVariableTable:
Start End Slot Name Signature
public static <T> void forEachWithIndex(java.lang.Iterable<T>, org.eclipse.collections.api.block.procedure.primitive.ObjectIntProcedure<? super T>);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/procedure/primitive/ObjectIntProcedure;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
getstatic org.eclipse.collections.impl.parallel.ParallelIterate.EXECUTOR_SERVICE:Ljava/util/concurrent/ExecutorService;
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEachWithIndex:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/procedure/primitive/ObjectIntProcedure;Ljava/util/concurrent/Executor;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 iterable Ljava/lang/Iterable<TT;>;
0 2 1 objectIntProcedure Lorg/eclipse/collections/api/block/procedure/primitive/ObjectIntProcedure<-TT;>;
Signature: <T:Ljava/lang/Object;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/procedure/primitive/ObjectIntProcedure<-TT;>;)V
MethodParameters:
Name Flags
iterable
objectIntProcedure
public static <T, BT extends org.eclipse.collections.api.block.procedure.primitive.ObjectIntProcedure<? super T>> void forEachWithIndex(java.lang.Iterable<T>, BT, java.util.concurrent.Executor);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/procedure/primitive/ObjectIntProcedure;Ljava/util/concurrent/Executor;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
1: new org.eclipse.collections.impl.parallel.PassThruObjectIntProcedureFactory
dup
aload 1
invokespecial org.eclipse.collections.impl.parallel.PassThruObjectIntProcedureFactory.<init>:(Lorg/eclipse/collections/api/block/procedure/primitive/ObjectIntProcedure;)V
2: new org.eclipse.collections.impl.parallel.PassThruCombiner
dup
invokespecial org.eclipse.collections.impl.parallel.PassThruCombiner.<init>:()V
aload 2
3: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEachWithIndex:(Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ObjectIntProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;Ljava/util/concurrent/Executor;)V
4: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 iterable Ljava/lang/Iterable<TT;>;
0 5 1 procedure TBT;
0 5 2 executor Ljava/util/concurrent/Executor;
Signature: <T:Ljava/lang/Object;BT::Lorg/eclipse/collections/api/block/procedure/primitive/ObjectIntProcedure<-TT;>;>(Ljava/lang/Iterable<TT;>;TBT;Ljava/util/concurrent/Executor;)V
MethodParameters:
Name Flags
iterable
procedure
executor
public static <T, BT extends org.eclipse.collections.api.block.procedure.primitive.ObjectIntProcedure<? super T>> void forEachWithIndex(java.lang.Iterable<T>, BT, int, );
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/procedure/primitive/ObjectIntProcedure;II)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
1: new org.eclipse.collections.impl.parallel.PassThruObjectIntProcedureFactory
dup
aload 1
invokespecial org.eclipse.collections.impl.parallel.PassThruObjectIntProcedureFactory.<init>:(Lorg/eclipse/collections/api/block/procedure/primitive/ObjectIntProcedure;)V
2: new org.eclipse.collections.impl.parallel.PassThruCombiner
dup
invokespecial org.eclipse.collections.impl.parallel.PassThruCombiner.<init>:()V
3: iload 2
4: iload 3
5: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEachWithIndex:(Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ObjectIntProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;II)V
6: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 iterable Ljava/lang/Iterable<TT;>;
0 7 1 procedure TBT;
0 7 2 minForkSize I
0 7 3 taskCount I
Signature: <T:Ljava/lang/Object;BT::Lorg/eclipse/collections/api/block/procedure/primitive/ObjectIntProcedure<-TT;>;>(Ljava/lang/Iterable<TT;>;TBT;II)V
MethodParameters:
Name Flags
iterable
procedure
minForkSize
taskCount
public static <T, BT extends org.eclipse.collections.api.block.procedure.primitive.ObjectIntProcedure<? super T>> void forEachWithIndex(java.lang.Iterable<T>, org.eclipse.collections.impl.parallel.ObjectIntProcedureFactory<BT>, org.eclipse.collections.impl.parallel.Combiner<BT>, java.util.concurrent.Executor);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ObjectIntProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;Ljava/util/concurrent/Executor;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: getstatic org.eclipse.collections.impl.parallel.ParallelIterate.DEFAULT_PARALLEL_TASK_COUNT:I
1: aload 0
invokestatic org.eclipse.collections.impl.utility.Iterate.sizeOf:(Ljava/lang/Iterable;)I
sipush 10000
idiv
2: invokestatic java.lang.Math.max:(II)I
istore 4
start local 4 3: aload 0
4: aload 1
5: aload 2
6: sipush 10000
7: iload 4
8: aload 3
9: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEachWithIndex:(Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ObjectIntProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;IILjava/util/concurrent/Executor;)V
10: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 iterable Ljava/lang/Iterable<TT;>;
0 11 1 procedureFactory Lorg/eclipse/collections/impl/parallel/ObjectIntProcedureFactory<TBT;>;
0 11 2 combiner Lorg/eclipse/collections/impl/parallel/Combiner<TBT;>;
0 11 3 executor Ljava/util/concurrent/Executor;
3 11 4 taskCount I
Signature: <T:Ljava/lang/Object;BT::Lorg/eclipse/collections/api/block/procedure/primitive/ObjectIntProcedure<-TT;>;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/impl/parallel/ObjectIntProcedureFactory<TBT;>;Lorg/eclipse/collections/impl/parallel/Combiner<TBT;>;Ljava/util/concurrent/Executor;)V
MethodParameters:
Name Flags
iterable
procedureFactory
combiner
executor
public static <T, BT extends org.eclipse.collections.api.block.procedure.primitive.ObjectIntProcedure<? super T>> void forEachWithIndex(java.lang.Iterable<T>, org.eclipse.collections.impl.parallel.ObjectIntProcedureFactory<BT>, org.eclipse.collections.impl.parallel.Combiner<BT>, int, );
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ObjectIntProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;II)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
aload 2
iload 3
iload 4
getstatic org.eclipse.collections.impl.parallel.ParallelIterate.EXECUTOR_SERVICE:Ljava/util/concurrent/ExecutorService;
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEachWithIndex:(Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ObjectIntProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;IILjava/util/concurrent/Executor;)V
1: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 iterable Ljava/lang/Iterable<TT;>;
0 2 1 procedureFactory Lorg/eclipse/collections/impl/parallel/ObjectIntProcedureFactory<TBT;>;
0 2 2 combiner Lorg/eclipse/collections/impl/parallel/Combiner<TBT;>;
0 2 3 minForkSize I
0 2 4 taskCount I
Signature: <T:Ljava/lang/Object;BT::Lorg/eclipse/collections/api/block/procedure/primitive/ObjectIntProcedure<-TT;>;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/impl/parallel/ObjectIntProcedureFactory<TBT;>;Lorg/eclipse/collections/impl/parallel/Combiner<TBT;>;II)V
MethodParameters:
Name Flags
iterable
procedureFactory
combiner
minForkSize
taskCount
public static <T, BT extends org.eclipse.collections.api.block.procedure.primitive.ObjectIntProcedure<? super T>> void forEachWithIndex(java.lang.Iterable<T>, org.eclipse.collections.impl.parallel.ObjectIntProcedureFactory<BT>, org.eclipse.collections.impl.parallel.Combiner<BT>, int, int, java.util.concurrent.Executor);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ObjectIntProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;IILjava/util/concurrent/Executor;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=6, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
invokestatic org.eclipse.collections.impl.utility.Iterate.notEmpty:(Ljava/lang/Iterable;)Z
ifeq 18
1: aload 0
instanceof java.util.RandomAccess
ifne 3
aload 0
instanceof org.eclipse.collections.api.list.ListIterable
ifeq 11
2: aload 0
instanceof java.util.List
ifeq 11
3: StackMap locals:
StackMap stack:
aload 0
checkcast java.util.List
4: aload 1
5: aload 2
6: iload 3
7: iload 4
8: aload 5
9: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEachWithIndexInListOnExecutor:(Ljava/util/List;Lorg/eclipse/collections/impl/parallel/ObjectIntProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;IILjava/util/concurrent/Executor;)V
10: goto 18
11: StackMap locals:
StackMap stack:
aload 0
invokestatic org.eclipse.collections.impl.utility.Iterate.toArray:(Ljava/lang/Iterable;)[Ljava/lang/Object;
invokestatic org.eclipse.collections.impl.list.fixed.ArrayAdapter.adapt:([Ljava/lang/Object;)Lorg/eclipse/collections/impl/list/fixed/ArrayAdapter;
12: aload 1
13: aload 2
14: iload 3
15: iload 4
16: aload 5
17: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEachWithIndexInListOnExecutor:(Ljava/util/List;Lorg/eclipse/collections/impl/parallel/ObjectIntProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;IILjava/util/concurrent/Executor;)V
18: StackMap locals:
StackMap stack:
return
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 19 0 iterable Ljava/lang/Iterable<TT;>;
0 19 1 procedureFactory Lorg/eclipse/collections/impl/parallel/ObjectIntProcedureFactory<TBT;>;
0 19 2 combiner Lorg/eclipse/collections/impl/parallel/Combiner<TBT;>;
0 19 3 minForkSize I
0 19 4 taskCount I
0 19 5 executor Ljava/util/concurrent/Executor;
Signature: <T:Ljava/lang/Object;BT::Lorg/eclipse/collections/api/block/procedure/primitive/ObjectIntProcedure<-TT;>;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/impl/parallel/ObjectIntProcedureFactory<TBT;>;Lorg/eclipse/collections/impl/parallel/Combiner<TBT;>;IILjava/util/concurrent/Executor;)V
MethodParameters:
Name Flags
iterable
procedureFactory
combiner
minForkSize
taskCount
executor
public static <T, BT extends org.eclipse.collections.api.block.procedure.primitive.ObjectIntProcedure<? super T>> void forEachWithIndexInListOnExecutor(java.util.List<T>, org.eclipse.collections.impl.parallel.ObjectIntProcedureFactory<BT>, org.eclipse.collections.impl.parallel.Combiner<BT>, int, int, java.util.concurrent.Executor);
descriptor: (Ljava/util/List;Lorg/eclipse/collections/impl/parallel/ObjectIntProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;IILjava/util/concurrent/Executor;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=9, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
invokeinterface java.util.List.size:()I
istore 6
start local 6 1: iload 6
iload 3
if_icmpge 9
2: aload 1
invokeinterface org.eclipse.collections.impl.parallel.ObjectIntProcedureFactory.create:()Lorg/eclipse/collections/api/block/procedure/primitive/ObjectIntProcedure;
astore 7
start local 7 3: aload 0
aload 7
invokestatic org.eclipse.collections.impl.utility.Iterate.forEachWithIndex:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/procedure/primitive/ObjectIntProcedure;)V
4: aload 2
invokeinterface org.eclipse.collections.impl.parallel.Combiner.useCombineOne:()Z
ifeq 7
5: aload 2
aload 7
invokeinterface org.eclipse.collections.impl.parallel.Combiner.combineOne:(Ljava/lang/Object;)V
6: goto 13
7: StackMap locals: int org.eclipse.collections.api.block.procedure.primitive.ObjectIntProcedure
StackMap stack:
aload 2
aload 7
invokestatic org.eclipse.collections.impl.factory.Iterables.iList:(Ljava/lang/Object;)Lorg/eclipse/collections/api/list/ImmutableList;
invokeinterface org.eclipse.collections.impl.parallel.Combiner.combineAll:(Ljava/lang/Iterable;)V
end local 7 8: goto 13
9: StackMap locals:
StackMap stack:
iload 6
iload 4
invokestatic java.lang.Math.min:(II)I
istore 7
start local 7 10: new org.eclipse.collections.impl.parallel.ObjectIntProcedureFJTaskRunner
dup
aload 2
iload 7
invokespecial org.eclipse.collections.impl.parallel.ObjectIntProcedureFJTaskRunner.<init>:(Lorg/eclipse/collections/impl/parallel/Combiner;I)V
11: astore 8
start local 8 12: aload 8
aload 5
aload 1
aload 0
invokevirtual org.eclipse.collections.impl.parallel.ObjectIntProcedureFJTaskRunner.executeAndCombine:(Ljava/util/concurrent/Executor;Lorg/eclipse/collections/impl/parallel/ObjectIntProcedureFactory;Ljava/util/List;)V
end local 8 end local 7 13: StackMap locals:
StackMap stack:
return
end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 list Ljava/util/List<TT;>;
0 14 1 procedureFactory Lorg/eclipse/collections/impl/parallel/ObjectIntProcedureFactory<TBT;>;
0 14 2 combiner Lorg/eclipse/collections/impl/parallel/Combiner<TBT;>;
0 14 3 minForkSize I
0 14 4 taskCount I
0 14 5 executor Ljava/util/concurrent/Executor;
1 14 6 size I
3 8 7 procedure TBT;
10 13 7 threadCount I
12 13 8 runner Lorg/eclipse/collections/impl/parallel/ObjectIntProcedureFJTaskRunner<TT;TBT;>;
Signature: <T:Ljava/lang/Object;BT::Lorg/eclipse/collections/api/block/procedure/primitive/ObjectIntProcedure<-TT;>;>(Ljava/util/List<TT;>;Lorg/eclipse/collections/impl/parallel/ObjectIntProcedureFactory<TBT;>;Lorg/eclipse/collections/impl/parallel/Combiner<TBT;>;IILjava/util/concurrent/Executor;)V
MethodParameters:
Name Flags
list
procedureFactory
combiner
minForkSize
taskCount
executor
public static <T> void forEach(java.lang.Iterable<T>, org.eclipse.collections.api.block.procedure.Procedure<? super T>);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/procedure/Procedure;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
getstatic org.eclipse.collections.impl.parallel.ParallelIterate.EXECUTOR_SERVICE:Ljava/util/concurrent/ExecutorService;
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEach:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/procedure/Procedure;Ljava/util/concurrent/Executor;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 iterable Ljava/lang/Iterable<TT;>;
0 2 1 procedure Lorg/eclipse/collections/api/block/procedure/Procedure<-TT;>;
Signature: <T:Ljava/lang/Object;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/procedure/Procedure<-TT;>;)V
MethodParameters:
Name Flags
iterable
procedure
public static <T> void forEach(java.lang.Iterable<T>, org.eclipse.collections.api.block.procedure.Procedure<? super T>, );
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/procedure/Procedure;I)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
iload 2
getstatic org.eclipse.collections.impl.parallel.ParallelIterate.EXECUTOR_SERVICE:Ljava/util/concurrent/ExecutorService;
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEach:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/procedure/Procedure;ILjava/util/concurrent/Executor;)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 iterable Ljava/lang/Iterable<TT;>;
0 2 1 procedure Lorg/eclipse/collections/api/block/procedure/Procedure<-TT;>;
0 2 2 batchSize I
Signature: <T:Ljava/lang/Object;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/procedure/Procedure<-TT;>;I)V
MethodParameters:
Name Flags
iterable
procedure
batchSize
public static <T> void forEach(java.lang.Iterable<T>, org.eclipse.collections.api.block.procedure.Procedure<? super T>, int, java.util.concurrent.Executor);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/procedure/Procedure;ILjava/util/concurrent/Executor;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
iload 2
aload 0
iload 2
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.calculateTaskCount:(Ljava/lang/Iterable;I)I
aload 3
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEach:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/procedure/Procedure;IILjava/util/concurrent/Executor;)V
1: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 iterable Ljava/lang/Iterable<TT;>;
0 2 1 procedure Lorg/eclipse/collections/api/block/procedure/Procedure<-TT;>;
0 2 2 batchSize I
0 2 3 executor Ljava/util/concurrent/Executor;
Signature: <T:Ljava/lang/Object;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/procedure/Procedure<-TT;>;ILjava/util/concurrent/Executor;)V
MethodParameters:
Name Flags
iterable
procedure
batchSize
executor
public static <T, BT extends org.eclipse.collections.api.block.procedure.Procedure<? super T>> void forEach(java.lang.Iterable<T>, BT, java.util.concurrent.Executor);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/procedure/Procedure;Ljava/util/concurrent/Executor;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
1: new org.eclipse.collections.impl.parallel.PassThruProcedureFactory
dup
aload 1
invokespecial org.eclipse.collections.impl.parallel.PassThruProcedureFactory.<init>:(Lorg/eclipse/collections/api/block/procedure/Procedure;)V
2: new org.eclipse.collections.impl.parallel.PassThruCombiner
dup
invokespecial org.eclipse.collections.impl.parallel.PassThruCombiner.<init>:()V
3: aload 2
4: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEach:(Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;Ljava/util/concurrent/Executor;)V
5: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 iterable Ljava/lang/Iterable<TT;>;
0 6 1 procedure TBT;
0 6 2 executor Ljava/util/concurrent/Executor;
Signature: <T:Ljava/lang/Object;BT::Lorg/eclipse/collections/api/block/procedure/Procedure<-TT;>;>(Ljava/lang/Iterable<TT;>;TBT;Ljava/util/concurrent/Executor;)V
MethodParameters:
Name Flags
iterable
procedure
executor
public static <T, BT extends org.eclipse.collections.api.block.procedure.Procedure<? super T>> void forEach(java.lang.Iterable<T>, BT, int, );
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/procedure/Procedure;II)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
iload 2
iload 3
getstatic org.eclipse.collections.impl.parallel.ParallelIterate.EXECUTOR_SERVICE:Ljava/util/concurrent/ExecutorService;
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEach:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/procedure/Procedure;IILjava/util/concurrent/Executor;)V
1: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 iterable Ljava/lang/Iterable<TT;>;
0 2 1 procedure TBT;
0 2 2 minForkSize I
0 2 3 taskCount I
Signature: <T:Ljava/lang/Object;BT::Lorg/eclipse/collections/api/block/procedure/Procedure<-TT;>;>(Ljava/lang/Iterable<TT;>;TBT;II)V
MethodParameters:
Name Flags
iterable
procedure
minForkSize
taskCount
public static <T, BT extends org.eclipse.collections.api.block.procedure.Procedure<? super T>> void forEach(java.lang.Iterable<T>, BT, int, int, java.util.concurrent.Executor);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/procedure/Procedure;IILjava/util/concurrent/Executor;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
1: new org.eclipse.collections.impl.parallel.PassThruProcedureFactory
dup
aload 1
invokespecial org.eclipse.collections.impl.parallel.PassThruProcedureFactory.<init>:(Lorg/eclipse/collections/api/block/procedure/Procedure;)V
2: new org.eclipse.collections.impl.parallel.PassThruCombiner
dup
invokespecial org.eclipse.collections.impl.parallel.PassThruCombiner.<init>:()V
3: iload 2
4: iload 3
5: aload 4
6: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEach:(Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;IILjava/util/concurrent/Executor;)V
7: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 iterable Ljava/lang/Iterable<TT;>;
0 8 1 procedure TBT;
0 8 2 minForkSize I
0 8 3 taskCount I
0 8 4 executor Ljava/util/concurrent/Executor;
Signature: <T:Ljava/lang/Object;BT::Lorg/eclipse/collections/api/block/procedure/Procedure<-TT;>;>(Ljava/lang/Iterable<TT;>;TBT;IILjava/util/concurrent/Executor;)V
MethodParameters:
Name Flags
iterable
procedure
minForkSize
taskCount
executor
public static <T, BT extends org.eclipse.collections.api.block.procedure.Procedure<? super T>> void forEach(java.lang.Iterable<T>, org.eclipse.collections.impl.parallel.ProcedureFactory<BT>, org.eclipse.collections.impl.parallel.Combiner<BT>, java.util.concurrent.Executor);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;Ljava/util/concurrent/Executor;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
sipush 10000
aload 3
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEach:(Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;ILjava/util/concurrent/Executor;)V
1: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 iterable Ljava/lang/Iterable<TT;>;
0 2 1 procedureFactory Lorg/eclipse/collections/impl/parallel/ProcedureFactory<TBT;>;
0 2 2 combiner Lorg/eclipse/collections/impl/parallel/Combiner<TBT;>;
0 2 3 executor Ljava/util/concurrent/Executor;
Signature: <T:Ljava/lang/Object;BT::Lorg/eclipse/collections/api/block/procedure/Procedure<-TT;>;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/impl/parallel/ProcedureFactory<TBT;>;Lorg/eclipse/collections/impl/parallel/Combiner<TBT;>;Ljava/util/concurrent/Executor;)V
MethodParameters:
Name Flags
iterable
procedureFactory
combiner
executor
public static <T, BT extends org.eclipse.collections.api.block.procedure.Procedure<? super T>> void forEach(java.lang.Iterable<T>, org.eclipse.collections.impl.parallel.ProcedureFactory<BT>, org.eclipse.collections.impl.parallel.Combiner<BT>);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
getstatic org.eclipse.collections.impl.parallel.ParallelIterate.EXECUTOR_SERVICE:Ljava/util/concurrent/ExecutorService;
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEach:(Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;Ljava/util/concurrent/Executor;)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 iterable Ljava/lang/Iterable<TT;>;
0 2 1 procedureFactory Lorg/eclipse/collections/impl/parallel/ProcedureFactory<TBT;>;
0 2 2 combiner Lorg/eclipse/collections/impl/parallel/Combiner<TBT;>;
Signature: <T:Ljava/lang/Object;BT::Lorg/eclipse/collections/api/block/procedure/Procedure<-TT;>;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/impl/parallel/ProcedureFactory<TBT;>;Lorg/eclipse/collections/impl/parallel/Combiner<TBT;>;)V
MethodParameters:
Name Flags
iterable
procedureFactory
combiner
public static <T, BT extends org.eclipse.collections.api.block.procedure.Procedure<? super T>> void forEach(java.lang.Iterable<T>, org.eclipse.collections.impl.parallel.ProcedureFactory<BT>, org.eclipse.collections.impl.parallel.Combiner<BT>, );
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;I)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
iload 3
getstatic org.eclipse.collections.impl.parallel.ParallelIterate.EXECUTOR_SERVICE:Ljava/util/concurrent/ExecutorService;
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEach:(Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;ILjava/util/concurrent/Executor;)V
1: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 iterable Ljava/lang/Iterable<TT;>;
0 2 1 procedureFactory Lorg/eclipse/collections/impl/parallel/ProcedureFactory<TBT;>;
0 2 2 combiner Lorg/eclipse/collections/impl/parallel/Combiner<TBT;>;
0 2 3 batchSize I
Signature: <T:Ljava/lang/Object;BT::Lorg/eclipse/collections/api/block/procedure/Procedure<-TT;>;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/impl/parallel/ProcedureFactory<TBT;>;Lorg/eclipse/collections/impl/parallel/Combiner<TBT;>;I)V
MethodParameters:
Name Flags
iterable
procedureFactory
combiner
batchSize
public static <T, BT extends org.eclipse.collections.api.block.procedure.Procedure<? super T>> void forEach(java.lang.Iterable<T>, org.eclipse.collections.impl.parallel.ProcedureFactory<BT>, org.eclipse.collections.impl.parallel.Combiner<BT>, int, java.util.concurrent.Executor);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;ILjava/util/concurrent/Executor;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
aload 2
iload 3
aload 0
iload 3
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.calculateTaskCount:(Ljava/lang/Iterable;I)I
aload 4
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEach:(Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;IILjava/util/concurrent/Executor;)V
1: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 iterable Ljava/lang/Iterable<TT;>;
0 2 1 procedureFactory Lorg/eclipse/collections/impl/parallel/ProcedureFactory<TBT;>;
0 2 2 combiner Lorg/eclipse/collections/impl/parallel/Combiner<TBT;>;
0 2 3 batchSize I
0 2 4 executor Ljava/util/concurrent/Executor;
Signature: <T:Ljava/lang/Object;BT::Lorg/eclipse/collections/api/block/procedure/Procedure<-TT;>;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/impl/parallel/ProcedureFactory<TBT;>;Lorg/eclipse/collections/impl/parallel/Combiner<TBT;>;ILjava/util/concurrent/Executor;)V
MethodParameters:
Name Flags
iterable
procedureFactory
combiner
batchSize
executor
public static <T, BT extends org.eclipse.collections.api.block.procedure.Procedure<? super T>> void forEach(java.lang.Iterable<T>, org.eclipse.collections.impl.parallel.ProcedureFactory<BT>, org.eclipse.collections.impl.parallel.Combiner<BT>, int, );
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;II)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
aload 2
iload 3
iload 4
getstatic org.eclipse.collections.impl.parallel.ParallelIterate.EXECUTOR_SERVICE:Ljava/util/concurrent/ExecutorService;
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEach:(Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;IILjava/util/concurrent/Executor;)V
1: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 iterable Ljava/lang/Iterable<TT;>;
0 2 1 procedureFactory Lorg/eclipse/collections/impl/parallel/ProcedureFactory<TBT;>;
0 2 2 combiner Lorg/eclipse/collections/impl/parallel/Combiner<TBT;>;
0 2 3 minForkSize I
0 2 4 taskCount I
Signature: <T:Ljava/lang/Object;BT::Lorg/eclipse/collections/api/block/procedure/Procedure<-TT;>;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/impl/parallel/ProcedureFactory<TBT;>;Lorg/eclipse/collections/impl/parallel/Combiner<TBT;>;II)V
MethodParameters:
Name Flags
iterable
procedureFactory
combiner
minForkSize
taskCount
public static <T, BT extends org.eclipse.collections.api.block.procedure.Procedure<? super T>> void forEach(java.lang.Iterable<T>, org.eclipse.collections.impl.parallel.ProcedureFactory<BT>, org.eclipse.collections.impl.parallel.Combiner<BT>, int, int, java.util.concurrent.Executor);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;IILjava/util/concurrent/Executor;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=6, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
invokestatic org.eclipse.collections.impl.utility.Iterate.notEmpty:(Ljava/lang/Iterable;)Z
ifeq 27
1: aload 0
instanceof org.eclipse.collections.impl.parallel.BatchIterable
ifeq 10
2: aload 0
checkcast org.eclipse.collections.impl.parallel.BatchIterable
3: aload 1
4: aload 2
5: iload 3
6: iload 4
7: aload 5
8: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEachInBatchWithExecutor:(Lorg/eclipse/collections/impl/parallel/BatchIterable;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;IILjava/util/concurrent/Executor;)V
9: goto 27
10: StackMap locals:
StackMap stack:
aload 0
instanceof java.util.RandomAccess
ifne 11
aload 0
instanceof org.eclipse.collections.api.list.ListIterable
ifeq 20
11: StackMap locals:
StackMap stack:
aload 0
instanceof java.util.List
ifeq 20
12: aload 0
checkcast java.util.List
13: aload 1
14: aload 2
15: iload 3
16: iload 4
17: aload 5
18: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEachInListOnExecutor:(Ljava/util/List;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;IILjava/util/concurrent/Executor;)V
19: goto 27
20: StackMap locals:
StackMap stack:
aload 0
invokestatic org.eclipse.collections.impl.utility.Iterate.toArray:(Ljava/lang/Iterable;)[Ljava/lang/Object;
21: aload 1
22: aload 2
23: iload 3
24: iload 4
25: aload 5
26: invokestatic org.eclipse.collections.impl.parallel.ParallelArrayIterate.forEachOn:([Ljava/lang/Object;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;IILjava/util/concurrent/Executor;)V
27: StackMap locals:
StackMap stack:
return
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 28 0 iterable Ljava/lang/Iterable<TT;>;
0 28 1 procedureFactory Lorg/eclipse/collections/impl/parallel/ProcedureFactory<TBT;>;
0 28 2 combiner Lorg/eclipse/collections/impl/parallel/Combiner<TBT;>;
0 28 3 minForkSize I
0 28 4 taskCount I
0 28 5 executor Ljava/util/concurrent/Executor;
Signature: <T:Ljava/lang/Object;BT::Lorg/eclipse/collections/api/block/procedure/Procedure<-TT;>;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/impl/parallel/ProcedureFactory<TBT;>;Lorg/eclipse/collections/impl/parallel/Combiner<TBT;>;IILjava/util/concurrent/Executor;)V
MethodParameters:
Name Flags
iterable
procedureFactory
combiner
minForkSize
taskCount
executor
public static <T, BT extends org.eclipse.collections.api.block.procedure.Procedure<? super T>> void forEachInListOnExecutor(java.util.List<T>, org.eclipse.collections.impl.parallel.ProcedureFactory<BT>, org.eclipse.collections.impl.parallel.Combiner<BT>, int, int, java.util.concurrent.Executor);
descriptor: (Ljava/util/List;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;IILjava/util/concurrent/Executor;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=9, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
invokeinterface java.util.List.size:()I
istore 6
start local 6 1: iload 6
iload 3
if_icmpge 9
2: aload 1
invokeinterface org.eclipse.collections.impl.parallel.ProcedureFactory.create:()Lorg/eclipse/collections/api/block/procedure/Procedure;
astore 7
start local 7 3: aload 0
aload 7
invokestatic org.eclipse.collections.impl.utility.Iterate.forEach:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/procedure/Procedure;)V
4: aload 2
invokeinterface org.eclipse.collections.impl.parallel.Combiner.useCombineOne:()Z
ifeq 7
5: aload 2
aload 7
invokeinterface org.eclipse.collections.impl.parallel.Combiner.combineOne:(Ljava/lang/Object;)V
6: goto 13
7: StackMap locals: int org.eclipse.collections.api.block.procedure.Procedure
StackMap stack:
aload 2
aload 7
invokestatic org.eclipse.collections.impl.factory.Iterables.iList:(Ljava/lang/Object;)Lorg/eclipse/collections/api/list/ImmutableList;
invokeinterface org.eclipse.collections.impl.parallel.Combiner.combineAll:(Ljava/lang/Iterable;)V
end local 7 8: goto 13
9: StackMap locals:
StackMap stack:
iload 6
iload 4
invokestatic java.lang.Math.min:(II)I
istore 7
start local 7 10: new org.eclipse.collections.impl.parallel.ProcedureFJTaskRunner
dup
aload 2
iload 7
invokespecial org.eclipse.collections.impl.parallel.ProcedureFJTaskRunner.<init>:(Lorg/eclipse/collections/impl/parallel/Combiner;I)V
11: astore 8
start local 8 12: aload 8
aload 5
aload 1
aload 0
invokevirtual org.eclipse.collections.impl.parallel.ProcedureFJTaskRunner.executeAndCombine:(Ljava/util/concurrent/Executor;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Ljava/util/List;)V
end local 8 end local 7 13: StackMap locals:
StackMap stack:
return
end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 list Ljava/util/List<TT;>;
0 14 1 procedureFactory Lorg/eclipse/collections/impl/parallel/ProcedureFactory<TBT;>;
0 14 2 combiner Lorg/eclipse/collections/impl/parallel/Combiner<TBT;>;
0 14 3 minForkSize I
0 14 4 taskCount I
0 14 5 executor Ljava/util/concurrent/Executor;
1 14 6 size I
3 8 7 procedure TBT;
10 13 7 threadCount I
12 13 8 runner Lorg/eclipse/collections/impl/parallel/ProcedureFJTaskRunner<TT;TBT;>;
Signature: <T:Ljava/lang/Object;BT::Lorg/eclipse/collections/api/block/procedure/Procedure<-TT;>;>(Ljava/util/List<TT;>;Lorg/eclipse/collections/impl/parallel/ProcedureFactory<TBT;>;Lorg/eclipse/collections/impl/parallel/Combiner<TBT;>;IILjava/util/concurrent/Executor;)V
MethodParameters:
Name Flags
list
procedureFactory
combiner
minForkSize
taskCount
executor
public static <T, BT extends org.eclipse.collections.api.block.procedure.Procedure<? super T>> void forEachInBatchWithExecutor(org.eclipse.collections.impl.parallel.BatchIterable<T>, org.eclipse.collections.impl.parallel.ProcedureFactory<BT>, org.eclipse.collections.impl.parallel.Combiner<BT>, int, int, java.util.concurrent.Executor);
descriptor: (Lorg/eclipse/collections/impl/parallel/BatchIterable;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;IILjava/util/concurrent/Executor;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=7, locals=9, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
invokeinterface org.eclipse.collections.impl.parallel.BatchIterable.size:()I
istore 6
start local 6 1: iload 6
iload 3
if_icmpge 9
2: aload 1
invokeinterface org.eclipse.collections.impl.parallel.ProcedureFactory.create:()Lorg/eclipse/collections/api/block/procedure/Procedure;
astore 7
start local 7 3: aload 0
aload 7
invokeinterface org.eclipse.collections.impl.parallel.BatchIterable.forEach:(Lorg/eclipse/collections/api/block/procedure/Procedure;)V
4: aload 2
invokeinterface org.eclipse.collections.impl.parallel.Combiner.useCombineOne:()Z
ifeq 7
5: aload 2
aload 7
invokeinterface org.eclipse.collections.impl.parallel.Combiner.combineOne:(Ljava/lang/Object;)V
6: goto 13
7: StackMap locals: int org.eclipse.collections.api.block.procedure.Procedure
StackMap stack:
aload 2
aload 7
invokestatic org.eclipse.collections.impl.factory.Iterables.iList:(Ljava/lang/Object;)Lorg/eclipse/collections/api/list/ImmutableList;
invokeinterface org.eclipse.collections.impl.parallel.Combiner.combineAll:(Ljava/lang/Iterable;)V
end local 7 8: goto 13
9: StackMap locals:
StackMap stack:
iload 6
iload 4
aload 0
iload 6
i2d
iload 4
i2d
ddiv
invokestatic java.lang.Math.ceil:(D)D
d2i
invokeinterface org.eclipse.collections.impl.parallel.BatchIterable.getBatchCount:(I)I
invokestatic java.lang.Math.min:(II)I
invokestatic java.lang.Math.min:(II)I
istore 7
start local 7 10: new org.eclipse.collections.impl.parallel.BatchIterableProcedureFJTaskRunner
dup
aload 2
iload 7
invokespecial org.eclipse.collections.impl.parallel.BatchIterableProcedureFJTaskRunner.<init>:(Lorg/eclipse/collections/impl/parallel/Combiner;I)V
11: astore 8
start local 8 12: aload 8
aload 5
aload 1
aload 0
invokevirtual org.eclipse.collections.impl.parallel.BatchIterableProcedureFJTaskRunner.executeAndCombine:(Ljava/util/concurrent/Executor;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Lorg/eclipse/collections/impl/parallel/BatchIterable;)V
end local 8 end local 7 13: StackMap locals:
StackMap stack:
return
end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 set Lorg/eclipse/collections/impl/parallel/BatchIterable<TT;>;
0 14 1 procedureFactory Lorg/eclipse/collections/impl/parallel/ProcedureFactory<TBT;>;
0 14 2 combiner Lorg/eclipse/collections/impl/parallel/Combiner<TBT;>;
0 14 3 minForkSize I
0 14 4 taskCount I
0 14 5 executor Ljava/util/concurrent/Executor;
1 14 6 size I
3 8 7 procedure TBT;
10 13 7 threadCount I
12 13 8 runner Lorg/eclipse/collections/impl/parallel/BatchIterableProcedureFJTaskRunner<TT;TBT;>;
Signature: <T:Ljava/lang/Object;BT::Lorg/eclipse/collections/api/block/procedure/Procedure<-TT;>;>(Lorg/eclipse/collections/impl/parallel/BatchIterable<TT;>;Lorg/eclipse/collections/impl/parallel/ProcedureFactory<TBT;>;Lorg/eclipse/collections/impl/parallel/Combiner<TBT;>;IILjava/util/concurrent/Executor;)V
MethodParameters:
Name Flags
set
procedureFactory
combiner
minForkSize
taskCount
executor
public static <T> java.util.Collection<T> select(java.lang.Iterable<T>, org.eclipse.collections.api.block.predicate.Predicate<? super T>);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/predicate/Predicate;)Ljava/util/Collection;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
iconst_0
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.select:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/predicate/Predicate;Z)Ljava/util/Collection;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 iterable Ljava/lang/Iterable<TT;>;
0 1 1 predicate Lorg/eclipse/collections/api/block/predicate/Predicate<-TT;>;
Signature: <T:Ljava/lang/Object;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/predicate/Predicate<-TT;>;)Ljava/util/Collection<TT;>;
MethodParameters:
Name Flags
iterable
predicate
public static <T> java.util.Collection<T> select(java.lang.Iterable<T>, org.eclipse.collections.api.block.predicate.Predicate<? super T>, boolean);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/predicate/Predicate;Z)Ljava/util/Collection;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aconst_null
iload 2
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.select:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/predicate/Predicate;Ljava/util/Collection;Z)Ljava/util/Collection;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 iterable Ljava/lang/Iterable<TT;>;
0 1 1 predicate Lorg/eclipse/collections/api/block/predicate/Predicate<-TT;>;
0 1 2 allowReorderedResult Z
Signature: <T:Ljava/lang/Object;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/predicate/Predicate<-TT;>;Z)Ljava/util/Collection<TT;>;
MethodParameters:
Name Flags
iterable
predicate
allowReorderedResult
public static <T, R extends java.util.Collection<T>> R select(java.lang.Iterable<T>, org.eclipse.collections.api.block.predicate.Predicate<? super T>, R, );
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/predicate/Predicate;Ljava/util/Collection;Z)Ljava/util/Collection;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
1: aload 1
2: aload 2
3: sipush 10000
4: getstatic org.eclipse.collections.impl.parallel.ParallelIterate.EXECUTOR_SERVICE:Ljava/util/concurrent/ExecutorService;
5: iload 3
6: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.select:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/predicate/Predicate;Ljava/util/Collection;ILjava/util/concurrent/Executor;Z)Ljava/util/Collection;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 iterable Ljava/lang/Iterable<TT;>;
0 7 1 predicate Lorg/eclipse/collections/api/block/predicate/Predicate<-TT;>;
0 7 2 target TR;
0 7 3 allowReorderedResult Z
Signature: <T:Ljava/lang/Object;R::Ljava/util/Collection<TT;>;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/predicate/Predicate<-TT;>;TR;Z)TR;
MethodParameters:
Name Flags
iterable
predicate
target
allowReorderedResult
public static <T, R extends java.util.Collection<T>> R select(java.lang.Iterable<T>, org.eclipse.collections.api.block.predicate.Predicate<? super T>, R, int, java.util.concurrent.Executor, );
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/predicate/Predicate;Ljava/util/Collection;ILjava/util/concurrent/Executor;Z)Ljava/util/Collection;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=8, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: new org.eclipse.collections.impl.parallel.FastListSelectProcedureCombiner
dup
aload 0
aload 2
bipush 10
iload 5
invokespecial org.eclipse.collections.impl.parallel.FastListSelectProcedureCombiner.<init>:(Ljava/lang/Iterable;Ljava/util/Collection;IZ)V
astore 6
start local 6 1: new org.eclipse.collections.impl.parallel.FastListSelectProcedureFactory
dup
aload 1
iload 3
invokespecial org.eclipse.collections.impl.parallel.FastListSelectProcedureFactory.<init>:(Lorg/eclipse/collections/api/block/predicate/Predicate;I)V
astore 7
start local 7 2: aload 0
3: aload 7
4: aload 6
5: iload 3
6: aload 0
iload 3
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.calculateTaskCount:(Ljava/lang/Iterable;I)I
7: aload 4
8: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEach:(Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;IILjava/util/concurrent/Executor;)V
9: aload 6
invokevirtual org.eclipse.collections.impl.parallel.FastListSelectProcedureCombiner.getResult:()Ljava/util/Collection;
areturn
end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 iterable Ljava/lang/Iterable<TT;>;
0 10 1 predicate Lorg/eclipse/collections/api/block/predicate/Predicate<-TT;>;
0 10 2 target TR;
0 10 3 batchSize I
0 10 4 executor Ljava/util/concurrent/Executor;
0 10 5 allowReorderedResult Z
1 10 6 combiner Lorg/eclipse/collections/impl/parallel/FastListSelectProcedureCombiner<TT;>;
2 10 7 procedureFactory Lorg/eclipse/collections/impl/parallel/FastListSelectProcedureFactory<TT;>;
Signature: <T:Ljava/lang/Object;R::Ljava/util/Collection<TT;>;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/predicate/Predicate<-TT;>;TR;ILjava/util/concurrent/Executor;Z)TR;
MethodParameters:
Name Flags
iterable
predicate
target
batchSize
executor
allowReorderedResult
private static <T> int calculateTaskCount(java.lang.Iterable<T>, );
descriptor: (Ljava/lang/Iterable;I)I
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
instanceof org.eclipse.collections.impl.parallel.BatchIterable
ifeq 2
1: aload 0
checkcast org.eclipse.collections.impl.parallel.BatchIterable
iload 1
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.calculateTaskCount:(Lorg/eclipse/collections/impl/parallel/BatchIterable;I)I
ireturn
2: StackMap locals:
StackMap stack:
aload 0
invokestatic org.eclipse.collections.impl.utility.Iterate.sizeOf:(Ljava/lang/Iterable;)I
iload 1
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.calculateTaskCount:(II)I
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 iterable Ljava/lang/Iterable<TT;>;
0 3 1 batchSize I
Signature: <T:Ljava/lang/Object;>(Ljava/lang/Iterable<TT;>;I)I
MethodParameters:
Name Flags
iterable
batchSize
private static <T> int calculateTaskCount(org.eclipse.collections.impl.parallel.BatchIterable<T>, );
descriptor: (Lorg/eclipse/collections/impl/parallel/BatchIterable;I)I
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: iconst_2
aload 0
iload 1
invokeinterface org.eclipse.collections.impl.parallel.BatchIterable.getBatchCount:(I)I
invokestatic java.lang.Math.max:(II)I
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 batchIterable Lorg/eclipse/collections/impl/parallel/BatchIterable<TT;>;
0 1 1 batchSize I
Signature: <T:Ljava/lang/Object;>(Lorg/eclipse/collections/impl/parallel/BatchIterable<TT;>;I)I
MethodParameters:
Name Flags
batchIterable
batchSize
private static int calculateTaskCount(int, int);
descriptor: (II)I
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: iconst_2
iload 0
iload 1
idiv
invokestatic java.lang.Math.max:(II)I
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 size I
0 1 1 batchSize I
MethodParameters:
Name Flags
size
batchSize
public static <T> java.util.Collection<T> reject(java.lang.Iterable<T>, org.eclipse.collections.api.block.predicate.Predicate<? super T>);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/predicate/Predicate;)Ljava/util/Collection;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
iconst_0
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.reject:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/predicate/Predicate;Z)Ljava/util/Collection;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 iterable Ljava/lang/Iterable<TT;>;
0 1 1 predicate Lorg/eclipse/collections/api/block/predicate/Predicate<-TT;>;
Signature: <T:Ljava/lang/Object;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/predicate/Predicate<-TT;>;)Ljava/util/Collection<TT;>;
MethodParameters:
Name Flags
iterable
predicate
public static <T> java.util.Collection<T> reject(java.lang.Iterable<T>, org.eclipse.collections.api.block.predicate.Predicate<? super T>, boolean);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/predicate/Predicate;Z)Ljava/util/Collection;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aconst_null
iload 2
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.reject:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/predicate/Predicate;Ljava/util/Collection;Z)Ljava/util/Collection;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 iterable Ljava/lang/Iterable<TT;>;
0 1 1 predicate Lorg/eclipse/collections/api/block/predicate/Predicate<-TT;>;
0 1 2 allowReorderedResult Z
Signature: <T:Ljava/lang/Object;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/predicate/Predicate<-TT;>;Z)Ljava/util/Collection<TT;>;
MethodParameters:
Name Flags
iterable
predicate
allowReorderedResult
public static <T, R extends java.util.Collection<T>> R reject(java.lang.Iterable<T>, org.eclipse.collections.api.block.predicate.Predicate<? super T>, R, );
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/predicate/Predicate;Ljava/util/Collection;Z)Ljava/util/Collection;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
1: aload 1
2: aload 2
3: sipush 10000
4: getstatic org.eclipse.collections.impl.parallel.ParallelIterate.EXECUTOR_SERVICE:Ljava/util/concurrent/ExecutorService;
5: iload 3
6: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.reject:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/predicate/Predicate;Ljava/util/Collection;ILjava/util/concurrent/Executor;Z)Ljava/util/Collection;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 iterable Ljava/lang/Iterable<TT;>;
0 7 1 predicate Lorg/eclipse/collections/api/block/predicate/Predicate<-TT;>;
0 7 2 target TR;
0 7 3 allowReorderedResult Z
Signature: <T:Ljava/lang/Object;R::Ljava/util/Collection<TT;>;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/predicate/Predicate<-TT;>;TR;Z)TR;
MethodParameters:
Name Flags
iterable
predicate
target
allowReorderedResult
public static <T, R extends java.util.Collection<T>> R reject(java.lang.Iterable<T>, org.eclipse.collections.api.block.predicate.Predicate<? super T>, R, int, java.util.concurrent.Executor, );
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/predicate/Predicate;Ljava/util/Collection;ILjava/util/concurrent/Executor;Z)Ljava/util/Collection;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=8, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: new org.eclipse.collections.impl.parallel.FastListRejectProcedureCombiner
dup
aload 0
aload 2
bipush 10
iload 5
invokespecial org.eclipse.collections.impl.parallel.FastListRejectProcedureCombiner.<init>:(Ljava/lang/Iterable;Ljava/util/Collection;IZ)V
astore 6
start local 6 1: new org.eclipse.collections.impl.parallel.FastListRejectProcedureFactory
dup
aload 1
iload 3
invokespecial org.eclipse.collections.impl.parallel.FastListRejectProcedureFactory.<init>:(Lorg/eclipse/collections/api/block/predicate/Predicate;I)V
astore 7
start local 7 2: aload 0
3: aload 7
4: aload 6
5: iload 3
6: aload 0
iload 3
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.calculateTaskCount:(Ljava/lang/Iterable;I)I
7: aload 4
8: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEach:(Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;IILjava/util/concurrent/Executor;)V
9: aload 6
invokevirtual org.eclipse.collections.impl.parallel.FastListRejectProcedureCombiner.getResult:()Ljava/util/Collection;
areturn
end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 iterable Ljava/lang/Iterable<TT;>;
0 10 1 predicate Lorg/eclipse/collections/api/block/predicate/Predicate<-TT;>;
0 10 2 target TR;
0 10 3 batchSize I
0 10 4 executor Ljava/util/concurrent/Executor;
0 10 5 allowReorderedResult Z
1 10 6 combiner Lorg/eclipse/collections/impl/parallel/FastListRejectProcedureCombiner<TT;>;
2 10 7 procedureFactory Lorg/eclipse/collections/impl/parallel/FastListRejectProcedureFactory<TT;>;
Signature: <T:Ljava/lang/Object;R::Ljava/util/Collection<TT;>;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/predicate/Predicate<-TT;>;TR;ILjava/util/concurrent/Executor;Z)TR;
MethodParameters:
Name Flags
iterable
predicate
target
batchSize
executor
allowReorderedResult
public static <T> int count(java.lang.Iterable<T>, org.eclipse.collections.api.block.predicate.Predicate<? super T>);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/predicate/Predicate;)I
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
sipush 10000
getstatic org.eclipse.collections.impl.parallel.ParallelIterate.EXECUTOR_SERVICE:Ljava/util/concurrent/ExecutorService;
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.count:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/predicate/Predicate;ILjava/util/concurrent/Executor;)I
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 iterable Ljava/lang/Iterable<TT;>;
0 1 1 predicate Lorg/eclipse/collections/api/block/predicate/Predicate<-TT;>;
Signature: <T:Ljava/lang/Object;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/predicate/Predicate<-TT;>;)I
MethodParameters:
Name Flags
iterable
predicate
public static <T> int count(java.lang.Iterable<T>, org.eclipse.collections.api.block.predicate.Predicate<? super T>, int, java.util.concurrent.Executor);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/predicate/Predicate;ILjava/util/concurrent/Executor;)I
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=6, args_size=4
start local 0 start local 1 start local 2 start local 3 0: new org.eclipse.collections.impl.parallel.CountCombiner
dup
invokespecial org.eclipse.collections.impl.parallel.CountCombiner.<init>:()V
astore 4
start local 4 1: new org.eclipse.collections.impl.parallel.CountProcedureFactory
dup
aload 1
invokespecial org.eclipse.collections.impl.parallel.CountProcedureFactory.<init>:(Lorg/eclipse/collections/api/block/predicate/Predicate;)V
astore 5
start local 5 2: aload 0
3: aload 5
4: aload 4
5: iload 2
6: aload 3
7: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEach:(Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;ILjava/util/concurrent/Executor;)V
8: aload 4
invokevirtual org.eclipse.collections.impl.parallel.CountCombiner.getCount:()I
ireturn
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 iterable Ljava/lang/Iterable<TT;>;
0 9 1 predicate Lorg/eclipse/collections/api/block/predicate/Predicate<-TT;>;
0 9 2 batchSize I
0 9 3 executor Ljava/util/concurrent/Executor;
1 9 4 combiner Lorg/eclipse/collections/impl/parallel/CountCombiner<TT;>;
2 9 5 procedureFactory Lorg/eclipse/collections/impl/parallel/CountProcedureFactory<TT;>;
Signature: <T:Ljava/lang/Object;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/predicate/Predicate<-TT;>;ILjava/util/concurrent/Executor;)I
MethodParameters:
Name Flags
iterable
predicate
batchSize
executor
public static <T, V> java.util.Collection<V> collect(java.lang.Iterable<T>, org.eclipse.collections.api.block.function.Function<? super T, V>);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;)Ljava/util/Collection;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
iconst_0
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.collect:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Z)Ljava/util/Collection;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 iterable Ljava/lang/Iterable<TT;>;
0 1 1 function Lorg/eclipse/collections/api/block/function/Function<-TT;TV;>;
Signature: <T:Ljava/lang/Object;V:Ljava/lang/Object;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/function/Function<-TT;TV;>;)Ljava/util/Collection<TV;>;
MethodParameters:
Name Flags
iterable
function
public static <T, V> java.util.Collection<V> collect(java.lang.Iterable<T>, org.eclipse.collections.api.block.function.Function<? super T, V>, boolean);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Z)Ljava/util/Collection;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aconst_null
iload 2
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.collect:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Ljava/util/Collection;Z)Ljava/util/Collection;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 iterable Ljava/lang/Iterable<TT;>;
0 1 1 function Lorg/eclipse/collections/api/block/function/Function<-TT;TV;>;
0 1 2 allowReorderedResult Z
Signature: <T:Ljava/lang/Object;V:Ljava/lang/Object;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/function/Function<-TT;TV;>;Z)Ljava/util/Collection<TV;>;
MethodParameters:
Name Flags
iterable
function
allowReorderedResult
public static <T, V, R extends java.util.Collection<V>> R collect(java.lang.Iterable<T>, org.eclipse.collections.api.block.function.Function<? super T, V>, R, );
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Ljava/util/Collection;Z)Ljava/util/Collection;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
1: aload 1
2: aload 2
3: sipush 10000
4: getstatic org.eclipse.collections.impl.parallel.ParallelIterate.EXECUTOR_SERVICE:Ljava/util/concurrent/ExecutorService;
5: iload 3
6: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.collect:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Ljava/util/Collection;ILjava/util/concurrent/Executor;Z)Ljava/util/Collection;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 iterable Ljava/lang/Iterable<TT;>;
0 7 1 function Lorg/eclipse/collections/api/block/function/Function<-TT;TV;>;
0 7 2 target TR;
0 7 3 allowReorderedResult Z
Signature: <T:Ljava/lang/Object;V:Ljava/lang/Object;R::Ljava/util/Collection<TV;>;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/function/Function<-TT;TV;>;TR;Z)TR;
MethodParameters:
Name Flags
iterable
function
target
allowReorderedResult
public static <T, V, R extends java.util.Collection<V>> R collect(java.lang.Iterable<T>, org.eclipse.collections.api.block.function.Function<? super T, V>, R, int, java.util.concurrent.Executor, );
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Ljava/util/Collection;ILjava/util/concurrent/Executor;Z)Ljava/util/Collection;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=10, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
invokestatic org.eclipse.collections.impl.utility.Iterate.sizeOf:(Ljava/lang/Iterable;)I
istore 6
start local 6 1: new org.eclipse.collections.impl.parallel.FastListCollectProcedureCombiner
dup
aload 0
aload 2
iload 6
iload 5
invokespecial org.eclipse.collections.impl.parallel.FastListCollectProcedureCombiner.<init>:(Ljava/lang/Iterable;Ljava/util/Collection;IZ)V
astore 7
start local 7 2: aload 0
iload 3
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.calculateTaskCount:(Ljava/lang/Iterable;I)I
istore 8
start local 8 3: new org.eclipse.collections.impl.parallel.FastListCollectProcedureFactory
dup
aload 1
iload 6
iload 8
idiv
invokespecial org.eclipse.collections.impl.parallel.FastListCollectProcedureFactory.<init>:(Lorg/eclipse/collections/api/block/function/Function;I)V
astore 9
start local 9 4: aload 0
5: aload 9
6: aload 7
7: iload 3
8: iload 8
9: aload 4
10: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEach:(Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;IILjava/util/concurrent/Executor;)V
11: aload 7
invokevirtual org.eclipse.collections.impl.parallel.FastListCollectProcedureCombiner.getResult:()Ljava/util/Collection;
areturn
end local 9 end local 8 end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 iterable Ljava/lang/Iterable<TT;>;
0 12 1 function Lorg/eclipse/collections/api/block/function/Function<-TT;TV;>;
0 12 2 target TR;
0 12 3 batchSize I
0 12 4 executor Ljava/util/concurrent/Executor;
0 12 5 allowReorderedResult Z
1 12 6 size I
2 12 7 combiner Lorg/eclipse/collections/impl/parallel/FastListCollectProcedureCombiner<TT;TV;>;
3 12 8 taskCount I
4 12 9 procedureFactory Lorg/eclipse/collections/impl/parallel/FastListCollectProcedureFactory<TT;TV;>;
Signature: <T:Ljava/lang/Object;V:Ljava/lang/Object;R::Ljava/util/Collection<TV;>;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/function/Function<-TT;TV;>;TR;ILjava/util/concurrent/Executor;Z)TR;
MethodParameters:
Name Flags
iterable
function
target
batchSize
executor
allowReorderedResult
public static <T, V> java.util.Collection<V> flatCollect(java.lang.Iterable<T>, org.eclipse.collections.api.block.function.Function<? super T, java.util.Collection<V>>);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;)Ljava/util/Collection;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
iconst_0
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.flatCollect:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Z)Ljava/util/Collection;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 iterable Ljava/lang/Iterable<TT;>;
0 1 1 function Lorg/eclipse/collections/api/block/function/Function<-TT;Ljava/util/Collection<TV;>;>;
Signature: <T:Ljava/lang/Object;V:Ljava/lang/Object;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/function/Function<-TT;Ljava/util/Collection<TV;>;>;)Ljava/util/Collection<TV;>;
MethodParameters:
Name Flags
iterable
function
public static <T, V> java.util.Collection<V> flatCollect(java.lang.Iterable<T>, org.eclipse.collections.api.block.function.Function<? super T, java.util.Collection<V>>, boolean);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Z)Ljava/util/Collection;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aconst_null
iload 2
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.flatCollect:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Ljava/util/Collection;Z)Ljava/util/Collection;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 iterable Ljava/lang/Iterable<TT;>;
0 1 1 function Lorg/eclipse/collections/api/block/function/Function<-TT;Ljava/util/Collection<TV;>;>;
0 1 2 allowReorderedResult Z
Signature: <T:Ljava/lang/Object;V:Ljava/lang/Object;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/function/Function<-TT;Ljava/util/Collection<TV;>;>;Z)Ljava/util/Collection<TV;>;
MethodParameters:
Name Flags
iterable
function
allowReorderedResult
public static <T, V, R extends java.util.Collection<V>> R flatCollect(java.lang.Iterable<T>, org.eclipse.collections.api.block.function.Function<? super T, java.util.Collection<V>>, R, );
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Ljava/util/Collection;Z)Ljava/util/Collection;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
1: aload 1
2: aload 2
3: sipush 10000
4: getstatic org.eclipse.collections.impl.parallel.ParallelIterate.EXECUTOR_SERVICE:Ljava/util/concurrent/ExecutorService;
5: iload 3
6: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.flatCollect:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Ljava/util/Collection;ILjava/util/concurrent/Executor;Z)Ljava/util/Collection;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 iterable Ljava/lang/Iterable<TT;>;
0 7 1 function Lorg/eclipse/collections/api/block/function/Function<-TT;Ljava/util/Collection<TV;>;>;
0 7 2 target TR;
0 7 3 allowReorderedResult Z
Signature: <T:Ljava/lang/Object;V:Ljava/lang/Object;R::Ljava/util/Collection<TV;>;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/function/Function<-TT;Ljava/util/Collection<TV;>;>;TR;Z)TR;
MethodParameters:
Name Flags
iterable
function
target
allowReorderedResult
public static <T, V, R extends java.util.Collection<V>> R flatCollect(java.lang.Iterable<T>, org.eclipse.collections.api.block.function.Function<? super T, java.util.Collection<V>>, R, int, java.util.concurrent.Executor, );
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Ljava/util/Collection;ILjava/util/concurrent/Executor;Z)Ljava/util/Collection;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=11, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
invokestatic org.eclipse.collections.impl.utility.Iterate.sizeOf:(Ljava/lang/Iterable;)I
istore 6
start local 6 1: aload 0
iload 3
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.calculateTaskCount:(Ljava/lang/Iterable;I)I
istore 7
start local 7 2: iload 6
iload 7
idiv
istore 8
start local 8 3: new org.eclipse.collections.impl.parallel.FlatCollectProcedureCombiner
dup
aload 0
aload 2
iload 6
iload 5
invokespecial org.eclipse.collections.impl.parallel.FlatCollectProcedureCombiner.<init>:(Ljava/lang/Iterable;Ljava/util/Collection;IZ)V
4: astore 9
start local 9 5: new org.eclipse.collections.impl.parallel.FlatCollectProcedureFactory
dup
aload 1
iload 8
invokespecial org.eclipse.collections.impl.parallel.FlatCollectProcedureFactory.<init>:(Lorg/eclipse/collections/api/block/function/Function;I)V
astore 10
start local 10 6: aload 0
7: aload 10
8: aload 9
9: iload 3
10: iload 7
11: aload 4
12: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEach:(Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;IILjava/util/concurrent/Executor;)V
13: aload 9
invokevirtual org.eclipse.collections.impl.parallel.FlatCollectProcedureCombiner.getResult:()Ljava/util/Collection;
areturn
end local 10 end local 9 end local 8 end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 iterable Ljava/lang/Iterable<TT;>;
0 14 1 function Lorg/eclipse/collections/api/block/function/Function<-TT;Ljava/util/Collection<TV;>;>;
0 14 2 target TR;
0 14 3 batchSize I
0 14 4 executor Ljava/util/concurrent/Executor;
0 14 5 allowReorderedResult Z
1 14 6 size I
2 14 7 taskCount I
3 14 8 taskSize I
5 14 9 combiner Lorg/eclipse/collections/impl/parallel/FlatCollectProcedureCombiner<TT;TV;>;
6 14 10 procedureFactory Lorg/eclipse/collections/impl/parallel/FlatCollectProcedureFactory<TT;TV;>;
Signature: <T:Ljava/lang/Object;V:Ljava/lang/Object;R::Ljava/util/Collection<TV;>;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/function/Function<-TT;Ljava/util/Collection<TV;>;>;TR;ILjava/util/concurrent/Executor;Z)TR;
MethodParameters:
Name Flags
iterable
function
target
batchSize
executor
allowReorderedResult
public static <T, V> java.util.Collection<V> collectIf(java.lang.Iterable<T>, org.eclipse.collections.api.block.predicate.Predicate<? super T>, org.eclipse.collections.api.block.function.Function<? super T, V>);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/predicate/Predicate;Lorg/eclipse/collections/api/block/function/Function;)Ljava/util/Collection;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
iconst_0
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.collectIf:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/predicate/Predicate;Lorg/eclipse/collections/api/block/function/Function;Z)Ljava/util/Collection;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 iterable Ljava/lang/Iterable<TT;>;
0 1 1 predicate Lorg/eclipse/collections/api/block/predicate/Predicate<-TT;>;
0 1 2 function Lorg/eclipse/collections/api/block/function/Function<-TT;TV;>;
Signature: <T:Ljava/lang/Object;V:Ljava/lang/Object;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/predicate/Predicate<-TT;>;Lorg/eclipse/collections/api/block/function/Function<-TT;TV;>;)Ljava/util/Collection<TV;>;
MethodParameters:
Name Flags
iterable
predicate
function
public static <T, V> java.util.Collection<V> collectIf(java.lang.Iterable<T>, org.eclipse.collections.api.block.predicate.Predicate<? super T>, org.eclipse.collections.api.block.function.Function<? super T, V>, boolean);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/predicate/Predicate;Lorg/eclipse/collections/api/block/function/Function;Z)Ljava/util/Collection;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
aconst_null
iload 3
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.collectIf:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/predicate/Predicate;Lorg/eclipse/collections/api/block/function/Function;Ljava/util/Collection;Z)Ljava/util/Collection;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 iterable Ljava/lang/Iterable<TT;>;
0 1 1 predicate Lorg/eclipse/collections/api/block/predicate/Predicate<-TT;>;
0 1 2 function Lorg/eclipse/collections/api/block/function/Function<-TT;TV;>;
0 1 3 allowReorderedResult Z
Signature: <T:Ljava/lang/Object;V:Ljava/lang/Object;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/predicate/Predicate<-TT;>;Lorg/eclipse/collections/api/block/function/Function<-TT;TV;>;Z)Ljava/util/Collection<TV;>;
MethodParameters:
Name Flags
iterable
predicate
function
allowReorderedResult
public static <T, V, R extends java.util.Collection<V>> R collectIf(java.lang.Iterable<T>, org.eclipse.collections.api.block.predicate.Predicate<? super T>, org.eclipse.collections.api.block.function.Function<? super T, V>, R, );
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/predicate/Predicate;Lorg/eclipse/collections/api/block/function/Function;Ljava/util/Collection;Z)Ljava/util/Collection;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=7, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
1: aload 1
2: aload 2
3: aload 3
4: sipush 10000
5: getstatic org.eclipse.collections.impl.parallel.ParallelIterate.EXECUTOR_SERVICE:Ljava/util/concurrent/ExecutorService;
6: iload 4
7: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.collectIf:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/predicate/Predicate;Lorg/eclipse/collections/api/block/function/Function;Ljava/util/Collection;ILjava/util/concurrent/Executor;Z)Ljava/util/Collection;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 iterable Ljava/lang/Iterable<TT;>;
0 8 1 predicate Lorg/eclipse/collections/api/block/predicate/Predicate<-TT;>;
0 8 2 function Lorg/eclipse/collections/api/block/function/Function<-TT;TV;>;
0 8 3 target TR;
0 8 4 allowReorderedResult Z
Signature: <T:Ljava/lang/Object;V:Ljava/lang/Object;R::Ljava/util/Collection<TV;>;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/predicate/Predicate<-TT;>;Lorg/eclipse/collections/api/block/function/Function<-TT;TV;>;TR;Z)TR;
MethodParameters:
Name Flags
iterable
predicate
function
target
allowReorderedResult
public static <T, V, R extends java.util.Collection<V>> R collectIf(java.lang.Iterable<T>, org.eclipse.collections.api.block.predicate.Predicate<? super T>, org.eclipse.collections.api.block.function.Function<? super T, V>, R, int, java.util.concurrent.Executor, );
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/predicate/Predicate;Lorg/eclipse/collections/api/block/function/Function;Ljava/util/Collection;ILjava/util/concurrent/Executor;Z)Ljava/util/Collection;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=9, args_size=7
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 0: new org.eclipse.collections.impl.parallel.FastListCollectIfProcedureCombiner
dup
aload 0
aload 3
bipush 10
iload 6
invokespecial org.eclipse.collections.impl.parallel.FastListCollectIfProcedureCombiner.<init>:(Ljava/lang/Iterable;Ljava/util/Collection;IZ)V
astore 7
start local 7 1: new org.eclipse.collections.impl.parallel.FastListCollectIfProcedureFactory
dup
aload 2
aload 1
iload 4
invokespecial org.eclipse.collections.impl.parallel.FastListCollectIfProcedureFactory.<init>:(Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/predicate/Predicate;I)V
astore 8
start local 8 2: aload 0
3: aload 8
4: aload 7
5: iload 4
6: aload 0
iload 4
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.calculateTaskCount:(Ljava/lang/Iterable;I)I
7: aload 5
8: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEach:(Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;IILjava/util/concurrent/Executor;)V
9: aload 7
invokevirtual org.eclipse.collections.impl.parallel.FastListCollectIfProcedureCombiner.getResult:()Ljava/util/Collection;
areturn
end local 8 end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 iterable Ljava/lang/Iterable<TT;>;
0 10 1 predicate Lorg/eclipse/collections/api/block/predicate/Predicate<-TT;>;
0 10 2 function Lorg/eclipse/collections/api/block/function/Function<-TT;TV;>;
0 10 3 target TR;
0 10 4 batchSize I
0 10 5 executor Ljava/util/concurrent/Executor;
0 10 6 allowReorderedResult Z
1 10 7 combiner Lorg/eclipse/collections/impl/parallel/FastListCollectIfProcedureCombiner<TT;TV;>;
2 10 8 procedureFactory Lorg/eclipse/collections/impl/parallel/FastListCollectIfProcedureFactory<TT;TV;>;
Signature: <T:Ljava/lang/Object;V:Ljava/lang/Object;R::Ljava/util/Collection<TV;>;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/predicate/Predicate<-TT;>;Lorg/eclipse/collections/api/block/function/Function<-TT;TV;>;TR;ILjava/util/concurrent/Executor;Z)TR;
MethodParameters:
Name Flags
iterable
predicate
function
target
batchSize
executor
allowReorderedResult
public static <K, V> org.eclipse.collections.api.multimap.MutableMultimap<K, V> groupBy(java.lang.Iterable<V>, org.eclipse.collections.api.block.function.Function<? super V, ? extends K>);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;)Lorg/eclipse/collections/api/multimap/MutableMultimap;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
sipush 10000
getstatic org.eclipse.collections.impl.parallel.ParallelIterate.EXECUTOR_SERVICE:Ljava/util/concurrent/ExecutorService;
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.groupBy:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;ILjava/util/concurrent/Executor;)Lorg/eclipse/collections/api/multimap/MutableMultimap;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 iterable Ljava/lang/Iterable<TV;>;
0 1 1 function Lorg/eclipse/collections/api/block/function/Function<-TV;+TK;>;
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Ljava/lang/Iterable<TV;>;Lorg/eclipse/collections/api/block/function/Function<-TV;+TK;>;)Lorg/eclipse/collections/api/multimap/MutableMultimap<TK;TV;>;
MethodParameters:
Name Flags
iterable
function
public static <T, K, V> org.eclipse.collections.api.map.MutableMap<K, V> aggregateBy(java.lang.Iterable<T>, org.eclipse.collections.api.block.function.Function<? super T, ? extends K>, org.eclipse.collections.api.block.function.Function0<? extends V>, org.eclipse.collections.api.block.function.Function2<? super V, ? super T, ? extends V>);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/Function0;Lorg/eclipse/collections/api/block/function/Function2;)Lorg/eclipse/collections/api/map/MutableMap;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
1: aload 1
2: aload 2
3: aload 3
4: sipush 10000
5: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.aggregateBy:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/Function0;Lorg/eclipse/collections/api/block/function/Function2;I)Lorg/eclipse/collections/api/map/MutableMap;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 iterable Ljava/lang/Iterable<TT;>;
0 6 1 groupBy Lorg/eclipse/collections/api/block/function/Function<-TT;+TK;>;
0 6 2 zeroValueFactory Lorg/eclipse/collections/api/block/function/Function0<+TV;>;
0 6 3 nonMutatingAggregator Lorg/eclipse/collections/api/block/function/Function2<-TV;-TT;+TV;>;
Signature: <T:Ljava/lang/Object;K:Ljava/lang/Object;V:Ljava/lang/Object;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/function/Function<-TT;+TK;>;Lorg/eclipse/collections/api/block/function/Function0<+TV;>;Lorg/eclipse/collections/api/block/function/Function2<-TV;-TT;+TV;>;)Lorg/eclipse/collections/api/map/MutableMap<TK;TV;>;
MethodParameters:
Name Flags
iterable
groupBy
zeroValueFactory
nonMutatingAggregator
public static <T, K, V, R extends org.eclipse.collections.api.map.MutableMapIterable<K, V>> R aggregateBy(java.lang.Iterable<T>, org.eclipse.collections.api.block.function.Function<? super T, ? extends K>, org.eclipse.collections.api.block.function.Function0<? extends V>, org.eclipse.collections.api.block.function.Function2<? super V, ? super T, ? extends V>, );
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/Function0;Lorg/eclipse/collections/api/block/function/Function2;Lorg/eclipse/collections/api/map/MutableMapIterable;)Lorg/eclipse/collections/api/map/MutableMapIterable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
1: aload 1
2: aload 2
3: aload 3
4: aload 4
5: sipush 10000
6: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.aggregateBy:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/Function0;Lorg/eclipse/collections/api/block/function/Function2;Lorg/eclipse/collections/api/map/MutableMapIterable;I)Lorg/eclipse/collections/api/map/MutableMapIterable;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 iterable Ljava/lang/Iterable<TT;>;
0 7 1 groupBy Lorg/eclipse/collections/api/block/function/Function<-TT;+TK;>;
0 7 2 zeroValueFactory Lorg/eclipse/collections/api/block/function/Function0<+TV;>;
0 7 3 nonMutatingAggregator Lorg/eclipse/collections/api/block/function/Function2<-TV;-TT;+TV;>;
0 7 4 mutableMap TR;
Signature: <T:Ljava/lang/Object;K:Ljava/lang/Object;V:Ljava/lang/Object;R::Lorg/eclipse/collections/api/map/MutableMapIterable<TK;TV;>;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/function/Function<-TT;+TK;>;Lorg/eclipse/collections/api/block/function/Function0<+TV;>;Lorg/eclipse/collections/api/block/function/Function2<-TV;-TT;+TV;>;TR;)TR;
MethodParameters:
Name Flags
iterable
groupBy
zeroValueFactory
nonMutatingAggregator
mutableMap
public static <T, K, V> org.eclipse.collections.api.map.MutableMap<K, V> aggregateBy(java.lang.Iterable<T>, org.eclipse.collections.api.block.function.Function<? super T, ? extends K>, org.eclipse.collections.api.block.function.Function0<? extends V>, org.eclipse.collections.api.block.function.Function2<? super V, ? super T, ? extends V>, int);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/Function0;Lorg/eclipse/collections/api/block/function/Function2;I)Lorg/eclipse/collections/api/map/MutableMap;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
1: aload 1
2: aload 2
3: aload 3
4: iload 4
5: getstatic org.eclipse.collections.impl.parallel.ParallelIterate.EXECUTOR_SERVICE:Ljava/util/concurrent/ExecutorService;
6: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.aggregateBy:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/Function0;Lorg/eclipse/collections/api/block/function/Function2;ILjava/util/concurrent/Executor;)Lorg/eclipse/collections/api/map/MutableMap;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 iterable Ljava/lang/Iterable<TT;>;
0 7 1 groupBy Lorg/eclipse/collections/api/block/function/Function<-TT;+TK;>;
0 7 2 zeroValueFactory Lorg/eclipse/collections/api/block/function/Function0<+TV;>;
0 7 3 nonMutatingAggregator Lorg/eclipse/collections/api/block/function/Function2<-TV;-TT;+TV;>;
0 7 4 batchSize I
Signature: <T:Ljava/lang/Object;K:Ljava/lang/Object;V:Ljava/lang/Object;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/function/Function<-TT;+TK;>;Lorg/eclipse/collections/api/block/function/Function0<+TV;>;Lorg/eclipse/collections/api/block/function/Function2<-TV;-TT;+TV;>;I)Lorg/eclipse/collections/api/map/MutableMap<TK;TV;>;
MethodParameters:
Name Flags
iterable
groupBy
zeroValueFactory
nonMutatingAggregator
batchSize
public static <T, K, V, R extends org.eclipse.collections.api.map.MutableMapIterable<K, V>> R aggregateBy(java.lang.Iterable<T>, org.eclipse.collections.api.block.function.Function<? super T, ? extends K>, org.eclipse.collections.api.block.function.Function0<? extends V>, org.eclipse.collections.api.block.function.Function2<? super V, ? super T, ? extends V>, R, );
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/Function0;Lorg/eclipse/collections/api/block/function/Function2;Lorg/eclipse/collections/api/map/MutableMapIterable;I)Lorg/eclipse/collections/api/map/MutableMapIterable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=7, locals=6, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
1: aload 1
2: aload 2
3: aload 3
4: aload 4
5: iload 5
6: getstatic org.eclipse.collections.impl.parallel.ParallelIterate.EXECUTOR_SERVICE:Ljava/util/concurrent/ExecutorService;
7: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.aggregateBy:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/Function0;Lorg/eclipse/collections/api/block/function/Function2;Lorg/eclipse/collections/api/map/MutableMapIterable;ILjava/util/concurrent/Executor;)Lorg/eclipse/collections/api/map/MutableMapIterable;
areturn
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 iterable Ljava/lang/Iterable<TT;>;
0 8 1 groupBy Lorg/eclipse/collections/api/block/function/Function<-TT;+TK;>;
0 8 2 zeroValueFactory Lorg/eclipse/collections/api/block/function/Function0<+TV;>;
0 8 3 nonMutatingAggregator Lorg/eclipse/collections/api/block/function/Function2<-TV;-TT;+TV;>;
0 8 4 mutableMap TR;
0 8 5 batchSize I
Signature: <T:Ljava/lang/Object;K:Ljava/lang/Object;V:Ljava/lang/Object;R::Lorg/eclipse/collections/api/map/MutableMapIterable<TK;TV;>;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/function/Function<-TT;+TK;>;Lorg/eclipse/collections/api/block/function/Function0<+TV;>;Lorg/eclipse/collections/api/block/function/Function2<-TV;-TT;+TV;>;TR;I)TR;
MethodParameters:
Name Flags
iterable
groupBy
zeroValueFactory
nonMutatingAggregator
mutableMap
batchSize
public static <T, K, V> org.eclipse.collections.api.map.MutableMap<K, V> aggregateBy(java.lang.Iterable<T>, org.eclipse.collections.api.block.function.Function<? super T, ? extends K>, org.eclipse.collections.api.block.function.Function0<? extends V>, org.eclipse.collections.api.block.function.Function2<? super V, ? super T, ? extends V>, int, java.util.concurrent.Executor);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/Function0;Lorg/eclipse/collections/api/block/function/Function2;ILjava/util/concurrent/Executor;)Lorg/eclipse/collections/api/map/MutableMap;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=7, locals=6, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
1: aload 1
2: aload 2
3: aload 3
4: invokestatic org.eclipse.collections.impl.map.mutable.ConcurrentHashMap.newMap:()Lorg/eclipse/collections/impl/map/mutable/ConcurrentHashMap;
5: iload 4
6: aload 5
7: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.aggregateBy:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/Function0;Lorg/eclipse/collections/api/block/function/Function2;Lorg/eclipse/collections/api/map/MutableMapIterable;ILjava/util/concurrent/Executor;)Lorg/eclipse/collections/api/map/MutableMapIterable;
checkcast org.eclipse.collections.api.map.MutableMap
areturn
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 iterable Ljava/lang/Iterable<TT;>;
0 8 1 groupBy Lorg/eclipse/collections/api/block/function/Function<-TT;+TK;>;
0 8 2 zeroValueFactory Lorg/eclipse/collections/api/block/function/Function0<+TV;>;
0 8 3 nonMutatingAggregator Lorg/eclipse/collections/api/block/function/Function2<-TV;-TT;+TV;>;
0 8 4 batchSize I
0 8 5 executor Ljava/util/concurrent/Executor;
Signature: <T:Ljava/lang/Object;K:Ljava/lang/Object;V:Ljava/lang/Object;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/function/Function<-TT;+TK;>;Lorg/eclipse/collections/api/block/function/Function0<+TV;>;Lorg/eclipse/collections/api/block/function/Function2<-TV;-TT;+TV;>;ILjava/util/concurrent/Executor;)Lorg/eclipse/collections/api/map/MutableMap<TK;TV;>;
MethodParameters:
Name Flags
iterable
groupBy
zeroValueFactory
nonMutatingAggregator
batchSize
executor
public static <T, K, V, R extends org.eclipse.collections.api.map.MutableMapIterable<K, V>> R aggregateBy(java.lang.Iterable<T>, org.eclipse.collections.api.block.function.Function<? super T, ? extends K>, org.eclipse.collections.api.block.function.Function0<? extends V>, org.eclipse.collections.api.block.function.Function2<? super V, ? super T, ? extends V>, R, int, java.util.concurrent.Executor);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/Function0;Lorg/eclipse/collections/api/block/function/Function2;Lorg/eclipse/collections/api/map/MutableMapIterable;ILjava/util/concurrent/Executor;)Lorg/eclipse/collections/api/map/MutableMapIterable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=8, args_size=7
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 0: new org.eclipse.collections.impl.block.procedure.NonMutatingAggregationProcedure
dup
aload 4
aload 1
aload 2
aload 3
invokespecial org.eclipse.collections.impl.block.procedure.NonMutatingAggregationProcedure.<init>:(Lorg/eclipse/collections/api/map/MutableMapIterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/Function0;Lorg/eclipse/collections/api/block/function/Function2;)V
1: astore 7
start local 7 2: aload 0
3: new org.eclipse.collections.impl.parallel.PassThruProcedureFactory
dup
aload 7
invokespecial org.eclipse.collections.impl.parallel.PassThruProcedureFactory.<init>:(Lorg/eclipse/collections/api/block/procedure/Procedure;)V
4: invokestatic org.eclipse.collections.impl.parallel.Combiners.passThru:()Lorg/eclipse/collections/impl/parallel/Combiner;
5: iload 5
6: aload 6
7: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEach:(Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;ILjava/util/concurrent/Executor;)V
8: aload 4
areturn
end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 iterable Ljava/lang/Iterable<TT;>;
0 9 1 groupBy Lorg/eclipse/collections/api/block/function/Function<-TT;+TK;>;
0 9 2 zeroValueFactory Lorg/eclipse/collections/api/block/function/Function0<+TV;>;
0 9 3 nonMutatingAggregator Lorg/eclipse/collections/api/block/function/Function2<-TV;-TT;+TV;>;
0 9 4 mutableMap TR;
0 9 5 batchSize I
0 9 6 executor Ljava/util/concurrent/Executor;
2 9 7 nonMutatingAggregationProcedure Lorg/eclipse/collections/impl/block/procedure/NonMutatingAggregationProcedure<TT;TK;TV;>;
Signature: <T:Ljava/lang/Object;K:Ljava/lang/Object;V:Ljava/lang/Object;R::Lorg/eclipse/collections/api/map/MutableMapIterable<TK;TV;>;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/function/Function<-TT;+TK;>;Lorg/eclipse/collections/api/block/function/Function0<+TV;>;Lorg/eclipse/collections/api/block/function/Function2<-TV;-TT;+TV;>;TR;ILjava/util/concurrent/Executor;)TR;
MethodParameters:
Name Flags
iterable
groupBy
zeroValueFactory
nonMutatingAggregator
mutableMap
batchSize
executor
public static <T, K, V> org.eclipse.collections.api.map.MutableMap<K, V> aggregateInPlaceBy(java.lang.Iterable<T>, org.eclipse.collections.api.block.function.Function<? super T, ? extends K>, org.eclipse.collections.api.block.function.Function0<? extends V>, org.eclipse.collections.api.block.procedure.Procedure2<? super V, ? super T>);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/Function0;Lorg/eclipse/collections/api/block/procedure/Procedure2;)Lorg/eclipse/collections/api/map/MutableMap;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
1: aload 1
2: aload 2
3: aload 3
4: sipush 10000
5: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.aggregateInPlaceBy:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/Function0;Lorg/eclipse/collections/api/block/procedure/Procedure2;I)Lorg/eclipse/collections/api/map/MutableMap;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 iterable Ljava/lang/Iterable<TT;>;
0 6 1 groupBy Lorg/eclipse/collections/api/block/function/Function<-TT;+TK;>;
0 6 2 zeroValueFactory Lorg/eclipse/collections/api/block/function/Function0<+TV;>;
0 6 3 mutatingAggregator Lorg/eclipse/collections/api/block/procedure/Procedure2<-TV;-TT;>;
Signature: <T:Ljava/lang/Object;K:Ljava/lang/Object;V:Ljava/lang/Object;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/function/Function<-TT;+TK;>;Lorg/eclipse/collections/api/block/function/Function0<+TV;>;Lorg/eclipse/collections/api/block/procedure/Procedure2<-TV;-TT;>;)Lorg/eclipse/collections/api/map/MutableMap<TK;TV;>;
MethodParameters:
Name Flags
iterable
groupBy
zeroValueFactory
mutatingAggregator
public static <T, K, V, R extends org.eclipse.collections.api.map.MutableMapIterable<K, V>> R aggregateInPlaceBy(java.lang.Iterable<T>, org.eclipse.collections.api.block.function.Function<? super T, ? extends K>, org.eclipse.collections.api.block.function.Function0<? extends V>, org.eclipse.collections.api.block.procedure.Procedure2<? super V, ? super T>, );
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/Function0;Lorg/eclipse/collections/api/block/procedure/Procedure2;Lorg/eclipse/collections/api/map/MutableMapIterable;)Lorg/eclipse/collections/api/map/MutableMapIterable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
1: aload 1
2: aload 2
3: aload 3
4: aload 4
5: sipush 10000
6: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.aggregateInPlaceBy:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/Function0;Lorg/eclipse/collections/api/block/procedure/Procedure2;Lorg/eclipse/collections/api/map/MutableMapIterable;I)Lorg/eclipse/collections/api/map/MutableMapIterable;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 iterable Ljava/lang/Iterable<TT;>;
0 7 1 groupBy Lorg/eclipse/collections/api/block/function/Function<-TT;+TK;>;
0 7 2 zeroValueFactory Lorg/eclipse/collections/api/block/function/Function0<+TV;>;
0 7 3 mutatingAggregator Lorg/eclipse/collections/api/block/procedure/Procedure2<-TV;-TT;>;
0 7 4 mutableMap TR;
Signature: <T:Ljava/lang/Object;K:Ljava/lang/Object;V:Ljava/lang/Object;R::Lorg/eclipse/collections/api/map/MutableMapIterable<TK;TV;>;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/function/Function<-TT;+TK;>;Lorg/eclipse/collections/api/block/function/Function0<+TV;>;Lorg/eclipse/collections/api/block/procedure/Procedure2<-TV;-TT;>;TR;)TR;
MethodParameters:
Name Flags
iterable
groupBy
zeroValueFactory
mutatingAggregator
mutableMap
public static <T, K, V> org.eclipse.collections.api.map.MutableMap<K, V> aggregateInPlaceBy(java.lang.Iterable<T>, org.eclipse.collections.api.block.function.Function<? super T, ? extends K>, org.eclipse.collections.api.block.function.Function0<? extends V>, org.eclipse.collections.api.block.procedure.Procedure2<? super V, ? super T>, int);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/Function0;Lorg/eclipse/collections/api/block/procedure/Procedure2;I)Lorg/eclipse/collections/api/map/MutableMap;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
1: aload 1
2: aload 2
3: aload 3
4: iload 4
5: getstatic org.eclipse.collections.impl.parallel.ParallelIterate.EXECUTOR_SERVICE:Ljava/util/concurrent/ExecutorService;
6: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.aggregateInPlaceBy:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/Function0;Lorg/eclipse/collections/api/block/procedure/Procedure2;ILjava/util/concurrent/Executor;)Lorg/eclipse/collections/api/map/MutableMap;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 iterable Ljava/lang/Iterable<TT;>;
0 7 1 groupBy Lorg/eclipse/collections/api/block/function/Function<-TT;+TK;>;
0 7 2 zeroValueFactory Lorg/eclipse/collections/api/block/function/Function0<+TV;>;
0 7 3 mutatingAggregator Lorg/eclipse/collections/api/block/procedure/Procedure2<-TV;-TT;>;
0 7 4 batchSize I
Signature: <T:Ljava/lang/Object;K:Ljava/lang/Object;V:Ljava/lang/Object;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/function/Function<-TT;+TK;>;Lorg/eclipse/collections/api/block/function/Function0<+TV;>;Lorg/eclipse/collections/api/block/procedure/Procedure2<-TV;-TT;>;I)Lorg/eclipse/collections/api/map/MutableMap<TK;TV;>;
MethodParameters:
Name Flags
iterable
groupBy
zeroValueFactory
mutatingAggregator
batchSize
public static <T, K, V, R extends org.eclipse.collections.api.map.MutableMapIterable<K, V>> R aggregateInPlaceBy(java.lang.Iterable<T>, org.eclipse.collections.api.block.function.Function<? super T, ? extends K>, org.eclipse.collections.api.block.function.Function0<? extends V>, org.eclipse.collections.api.block.procedure.Procedure2<? super V, ? super T>, R, );
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/Function0;Lorg/eclipse/collections/api/block/procedure/Procedure2;Lorg/eclipse/collections/api/map/MutableMapIterable;I)Lorg/eclipse/collections/api/map/MutableMapIterable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=7, locals=6, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
1: aload 1
2: aload 2
3: aload 3
4: aload 4
5: iload 5
6: getstatic org.eclipse.collections.impl.parallel.ParallelIterate.EXECUTOR_SERVICE:Ljava/util/concurrent/ExecutorService;
7: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.aggregateInPlaceBy:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/Function0;Lorg/eclipse/collections/api/block/procedure/Procedure2;Lorg/eclipse/collections/api/map/MutableMapIterable;ILjava/util/concurrent/Executor;)Lorg/eclipse/collections/api/map/MutableMapIterable;
areturn
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 iterable Ljava/lang/Iterable<TT;>;
0 8 1 groupBy Lorg/eclipse/collections/api/block/function/Function<-TT;+TK;>;
0 8 2 zeroValueFactory Lorg/eclipse/collections/api/block/function/Function0<+TV;>;
0 8 3 mutatingAggregator Lorg/eclipse/collections/api/block/procedure/Procedure2<-TV;-TT;>;
0 8 4 mutableMap TR;
0 8 5 batchSize I
Signature: <T:Ljava/lang/Object;K:Ljava/lang/Object;V:Ljava/lang/Object;R::Lorg/eclipse/collections/api/map/MutableMapIterable<TK;TV;>;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/function/Function<-TT;+TK;>;Lorg/eclipse/collections/api/block/function/Function0<+TV;>;Lorg/eclipse/collections/api/block/procedure/Procedure2<-TV;-TT;>;TR;I)TR;
MethodParameters:
Name Flags
iterable
groupBy
zeroValueFactory
mutatingAggregator
mutableMap
batchSize
public static <T, K, V> org.eclipse.collections.api.map.MutableMap<K, V> aggregateInPlaceBy(java.lang.Iterable<T>, org.eclipse.collections.api.block.function.Function<? super T, ? extends K>, org.eclipse.collections.api.block.function.Function0<? extends V>, org.eclipse.collections.api.block.procedure.Procedure2<? super V, ? super T>, int, java.util.concurrent.Executor);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/Function0;Lorg/eclipse/collections/api/block/procedure/Procedure2;ILjava/util/concurrent/Executor;)Lorg/eclipse/collections/api/map/MutableMap;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=8, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: invokestatic org.eclipse.collections.impl.map.mutable.ConcurrentHashMap.newMap:()Lorg/eclipse/collections/impl/map/mutable/ConcurrentHashMap;
astore 6
start local 6 1: new org.eclipse.collections.impl.block.procedure.MutatingAggregationProcedure
dup
aload 6
aload 1
aload 2
aload 3
invokespecial org.eclipse.collections.impl.block.procedure.MutatingAggregationProcedure.<init>:(Lorg/eclipse/collections/api/map/MutableMapIterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/Function0;Lorg/eclipse/collections/api/block/procedure/Procedure2;)V
2: astore 7
start local 7 3: aload 0
4: new org.eclipse.collections.impl.parallel.PassThruProcedureFactory
dup
aload 7
invokespecial org.eclipse.collections.impl.parallel.PassThruProcedureFactory.<init>:(Lorg/eclipse/collections/api/block/procedure/Procedure;)V
5: invokestatic org.eclipse.collections.impl.parallel.Combiners.passThru:()Lorg/eclipse/collections/impl/parallel/Combiner;
6: iload 4
7: aload 5
8: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEach:(Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;ILjava/util/concurrent/Executor;)V
9: aload 6
areturn
end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 iterable Ljava/lang/Iterable<TT;>;
0 10 1 groupBy Lorg/eclipse/collections/api/block/function/Function<-TT;+TK;>;
0 10 2 zeroValueFactory Lorg/eclipse/collections/api/block/function/Function0<+TV;>;
0 10 3 mutatingAggregator Lorg/eclipse/collections/api/block/procedure/Procedure2<-TV;-TT;>;
0 10 4 batchSize I
0 10 5 executor Ljava/util/concurrent/Executor;
1 10 6 map Lorg/eclipse/collections/api/map/MutableMap<TK;TV;>;
3 10 7 mutatingAggregationProcedure Lorg/eclipse/collections/impl/block/procedure/MutatingAggregationProcedure<TT;TK;TV;>;
Signature: <T:Ljava/lang/Object;K:Ljava/lang/Object;V:Ljava/lang/Object;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/function/Function<-TT;+TK;>;Lorg/eclipse/collections/api/block/function/Function0<+TV;>;Lorg/eclipse/collections/api/block/procedure/Procedure2<-TV;-TT;>;ILjava/util/concurrent/Executor;)Lorg/eclipse/collections/api/map/MutableMap<TK;TV;>;
MethodParameters:
Name Flags
iterable
groupBy
zeroValueFactory
mutatingAggregator
batchSize
executor
public static <T, K, V, R extends org.eclipse.collections.api.map.MutableMapIterable<K, V>> R aggregateInPlaceBy(java.lang.Iterable<T>, org.eclipse.collections.api.block.function.Function<? super T, ? extends K>, org.eclipse.collections.api.block.function.Function0<? extends V>, org.eclipse.collections.api.block.procedure.Procedure2<? super V, ? super T>, R, int, java.util.concurrent.Executor);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/Function0;Lorg/eclipse/collections/api/block/procedure/Procedure2;Lorg/eclipse/collections/api/map/MutableMapIterable;ILjava/util/concurrent/Executor;)Lorg/eclipse/collections/api/map/MutableMapIterable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=8, args_size=7
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 0: new org.eclipse.collections.impl.block.procedure.MutatingAggregationProcedure
dup
aload 4
aload 1
aload 2
aload 3
invokespecial org.eclipse.collections.impl.block.procedure.MutatingAggregationProcedure.<init>:(Lorg/eclipse/collections/api/map/MutableMapIterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/Function0;Lorg/eclipse/collections/api/block/procedure/Procedure2;)V
1: astore 7
start local 7 2: aload 0
3: new org.eclipse.collections.impl.parallel.PassThruProcedureFactory
dup
aload 7
invokespecial org.eclipse.collections.impl.parallel.PassThruProcedureFactory.<init>:(Lorg/eclipse/collections/api/block/procedure/Procedure;)V
4: invokestatic org.eclipse.collections.impl.parallel.Combiners.passThru:()Lorg/eclipse/collections/impl/parallel/Combiner;
5: iload 5
6: aload 6
7: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEach:(Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;ILjava/util/concurrent/Executor;)V
8: aload 4
areturn
end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 iterable Ljava/lang/Iterable<TT;>;
0 9 1 groupBy Lorg/eclipse/collections/api/block/function/Function<-TT;+TK;>;
0 9 2 zeroValueFactory Lorg/eclipse/collections/api/block/function/Function0<+TV;>;
0 9 3 mutatingAggregator Lorg/eclipse/collections/api/block/procedure/Procedure2<-TV;-TT;>;
0 9 4 mutableMap TR;
0 9 5 batchSize I
0 9 6 executor Ljava/util/concurrent/Executor;
2 9 7 mutatingAggregationProcedure Lorg/eclipse/collections/impl/block/procedure/MutatingAggregationProcedure<TT;TK;TV;>;
Signature: <T:Ljava/lang/Object;K:Ljava/lang/Object;V:Ljava/lang/Object;R::Lorg/eclipse/collections/api/map/MutableMapIterable<TK;TV;>;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/function/Function<-TT;+TK;>;Lorg/eclipse/collections/api/block/function/Function0<+TV;>;Lorg/eclipse/collections/api/block/procedure/Procedure2<-TV;-TT;>;TR;ILjava/util/concurrent/Executor;)TR;
MethodParameters:
Name Flags
iterable
groupBy
zeroValueFactory
mutatingAggregator
mutableMap
batchSize
executor
public static <K, V, R extends org.eclipse.collections.api.multimap.MutableMultimap<K, V>> org.eclipse.collections.api.multimap.MutableMultimap<K, V> groupBy(java.lang.Iterable<V>, org.eclipse.collections.api.block.function.Function<? super V, ? extends K>, R);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/multimap/MutableMultimap;)Lorg/eclipse/collections/api/multimap/MutableMultimap;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
sipush 10000
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.groupBy:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/multimap/MutableMultimap;I)Lorg/eclipse/collections/api/multimap/MutableMultimap;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 iterable Ljava/lang/Iterable<TV;>;
0 1 1 function Lorg/eclipse/collections/api/block/function/Function<-TV;+TK;>;
0 1 2 concurrentMultimap TR;
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;R::Lorg/eclipse/collections/api/multimap/MutableMultimap<TK;TV;>;>(Ljava/lang/Iterable<TV;>;Lorg/eclipse/collections/api/block/function/Function<-TV;+TK;>;TR;)Lorg/eclipse/collections/api/multimap/MutableMultimap<TK;TV;>;
MethodParameters:
Name Flags
iterable
function
concurrentMultimap
public static <K, V, R extends org.eclipse.collections.api.multimap.MutableMultimap<K, V>> org.eclipse.collections.api.multimap.MutableMultimap<K, V> groupBy(java.lang.Iterable<V>, org.eclipse.collections.api.block.function.Function<? super V, ? extends K>, R, int);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/multimap/MutableMultimap;I)Lorg/eclipse/collections/api/multimap/MutableMultimap;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
iload 3
getstatic org.eclipse.collections.impl.parallel.ParallelIterate.EXECUTOR_SERVICE:Ljava/util/concurrent/ExecutorService;
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.groupBy:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/multimap/MutableMultimap;ILjava/util/concurrent/Executor;)Lorg/eclipse/collections/api/multimap/MutableMultimap;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 iterable Ljava/lang/Iterable<TV;>;
0 1 1 function Lorg/eclipse/collections/api/block/function/Function<-TV;+TK;>;
0 1 2 concurrentMultimap TR;
0 1 3 batchSize I
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;R::Lorg/eclipse/collections/api/multimap/MutableMultimap<TK;TV;>;>(Ljava/lang/Iterable<TV;>;Lorg/eclipse/collections/api/block/function/Function<-TV;+TK;>;TR;I)Lorg/eclipse/collections/api/multimap/MutableMultimap<TK;TV;>;
MethodParameters:
Name Flags
iterable
function
concurrentMultimap
batchSize
public static <K, V> org.eclipse.collections.api.multimap.MutableMultimap<K, V> groupBy(java.lang.Iterable<V>, org.eclipse.collections.api.block.function.Function<? super V, ? extends K>, int);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;I)Lorg/eclipse/collections/api/multimap/MutableMultimap;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
iload 2
getstatic org.eclipse.collections.impl.parallel.ParallelIterate.EXECUTOR_SERVICE:Ljava/util/concurrent/ExecutorService;
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.groupBy:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;ILjava/util/concurrent/Executor;)Lorg/eclipse/collections/api/multimap/MutableMultimap;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 iterable Ljava/lang/Iterable<TV;>;
0 1 1 function Lorg/eclipse/collections/api/block/function/Function<-TV;+TK;>;
0 1 2 batchSize I
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Ljava/lang/Iterable<TV;>;Lorg/eclipse/collections/api/block/function/Function<-TV;+TK;>;I)Lorg/eclipse/collections/api/multimap/MutableMultimap<TK;TV;>;
MethodParameters:
Name Flags
iterable
function
batchSize
public static <K, V> org.eclipse.collections.api.multimap.MutableMultimap<K, V> groupBy(java.lang.Iterable<V>, org.eclipse.collections.api.block.function.Function<? super V, ? extends K>, int, java.util.concurrent.Executor);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;ILjava/util/concurrent/Executor;)Lorg/eclipse/collections/api/multimap/MutableMultimap;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
invokestatic org.eclipse.collections.impl.multimap.list.SynchronizedPutFastListMultimap.newMultimap:()Lorg/eclipse/collections/impl/multimap/list/SynchronizedPutFastListMultimap;
iload 2
aload 3
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.groupBy:(Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/multimap/MutableMultimap;ILjava/util/concurrent/Executor;)Lorg/eclipse/collections/api/multimap/MutableMultimap;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 iterable Ljava/lang/Iterable<TV;>;
0 1 1 function Lorg/eclipse/collections/api/block/function/Function<-TV;+TK;>;
0 1 2 batchSize I
0 1 3 executor Ljava/util/concurrent/Executor;
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Ljava/lang/Iterable<TV;>;Lorg/eclipse/collections/api/block/function/Function<-TV;+TK;>;ILjava/util/concurrent/Executor;)Lorg/eclipse/collections/api/multimap/MutableMultimap<TK;TV;>;
MethodParameters:
Name Flags
iterable
function
batchSize
executor
public static <K, V, R extends org.eclipse.collections.api.multimap.MutableMultimap<K, V>> org.eclipse.collections.api.multimap.MutableMultimap<K, V> groupBy(java.lang.Iterable<V>, org.eclipse.collections.api.block.function.Function<? super V, ? extends K>, R, int, java.util.concurrent.Executor);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/multimap/MutableMultimap;ILjava/util/concurrent/Executor;)Lorg/eclipse/collections/api/multimap/MutableMultimap;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=7, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
1: new org.eclipse.collections.impl.parallel.PassThruProcedureFactory
dup
new org.eclipse.collections.impl.block.procedure.MultimapPutProcedure
dup
aload 2
aload 1
invokespecial org.eclipse.collections.impl.block.procedure.MultimapPutProcedure.<init>:(Lorg/eclipse/collections/api/multimap/MutableMultimap;Lorg/eclipse/collections/api/block/function/Function;)V
invokespecial org.eclipse.collections.impl.parallel.PassThruProcedureFactory.<init>:(Lorg/eclipse/collections/api/block/procedure/Procedure;)V
2: invokestatic org.eclipse.collections.impl.parallel.Combiners.passThru:()Lorg/eclipse/collections/impl/parallel/Combiner;
3: iload 3
4: aload 4
5: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEach:(Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;ILjava/util/concurrent/Executor;)V
6: aload 2
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 iterable Ljava/lang/Iterable<TV;>;
0 7 1 function Lorg/eclipse/collections/api/block/function/Function<-TV;+TK;>;
0 7 2 concurrentMultimap TR;
0 7 3 batchSize I
0 7 4 executor Ljava/util/concurrent/Executor;
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;R::Lorg/eclipse/collections/api/multimap/MutableMultimap<TK;TV;>;>(Ljava/lang/Iterable<TV;>;Lorg/eclipse/collections/api/block/function/Function<-TV;+TK;>;TR;ILjava/util/concurrent/Executor;)Lorg/eclipse/collections/api/multimap/MutableMultimap<TK;TV;>;
MethodParameters:
Name Flags
iterable
function
concurrentMultimap
batchSize
executor
public static <T, V> org.eclipse.collections.api.map.primitive.ObjectDoubleMap<V> sumByDouble(java.lang.Iterable<T>, org.eclipse.collections.api.block.function.Function<? super T, ? extends V>, org.eclipse.collections.api.block.function.primitive.DoubleFunction<? super T>);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/primitive/DoubleFunction;)Lorg/eclipse/collections/api/map/primitive/ObjectDoubleMap;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=4, args_size=3
start local 0 start local 1 start local 2 0: invokestatic org.eclipse.collections.impl.map.mutable.primitive.ObjectDoubleHashMap.newMap:()Lorg/eclipse/collections/impl/map/mutable/primitive/ObjectDoubleHashMap;
astore 3
start local 3 1: aload 0
2: new org.eclipse.collections.impl.parallel.ParallelIterate$SumByDoubleProcedure
dup
aload 1
aload 2
invokespecial org.eclipse.collections.impl.parallel.ParallelIterate$SumByDoubleProcedure.<init>:(Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/primitive/DoubleFunction;)V
3: new org.eclipse.collections.impl.parallel.ParallelIterate$SumByDoubleCombiner
dup
aload 3
invokespecial org.eclipse.collections.impl.parallel.ParallelIterate$SumByDoubleCombiner.<init>:(Lorg/eclipse/collections/impl/map/mutable/primitive/ObjectDoubleHashMap;)V
4: sipush 10000
5: getstatic org.eclipse.collections.impl.parallel.ParallelIterate.EXECUTOR_SERVICE:Ljava/util/concurrent/ExecutorService;
6: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEach:(Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;ILjava/util/concurrent/Executor;)V
7: aload 3
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 iterable Ljava/lang/Iterable<TT;>;
0 8 1 groupBy Lorg/eclipse/collections/api/block/function/Function<-TT;+TV;>;
0 8 2 function Lorg/eclipse/collections/api/block/function/primitive/DoubleFunction<-TT;>;
1 8 3 result Lorg/eclipse/collections/impl/map/mutable/primitive/ObjectDoubleHashMap<TV;>;
Signature: <T:Ljava/lang/Object;V:Ljava/lang/Object;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/function/Function<-TT;+TV;>;Lorg/eclipse/collections/api/block/function/primitive/DoubleFunction<-TT;>;)Lorg/eclipse/collections/api/map/primitive/ObjectDoubleMap<TV;>;
MethodParameters:
Name Flags
iterable
groupBy
function
public static <T, V> org.eclipse.collections.api.map.primitive.ObjectDoubleMap<V> sumByFloat(java.lang.Iterable<T>, org.eclipse.collections.api.block.function.Function<? super T, ? extends V>, org.eclipse.collections.api.block.function.primitive.FloatFunction<? super T>);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/primitive/FloatFunction;)Lorg/eclipse/collections/api/map/primitive/ObjectDoubleMap;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=4, args_size=3
start local 0 start local 1 start local 2 0: invokestatic org.eclipse.collections.impl.map.mutable.primitive.ObjectDoubleHashMap.newMap:()Lorg/eclipse/collections/impl/map/mutable/primitive/ObjectDoubleHashMap;
astore 3
start local 3 1: aload 0
2: new org.eclipse.collections.impl.parallel.ParallelIterate$SumByFloatProcedure
dup
aload 1
aload 2
invokespecial org.eclipse.collections.impl.parallel.ParallelIterate$SumByFloatProcedure.<init>:(Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/primitive/FloatFunction;)V
3: new org.eclipse.collections.impl.parallel.ParallelIterate$SumByFloatCombiner
dup
aload 3
invokespecial org.eclipse.collections.impl.parallel.ParallelIterate$SumByFloatCombiner.<init>:(Lorg/eclipse/collections/impl/map/mutable/primitive/ObjectDoubleHashMap;)V
4: sipush 10000
5: getstatic org.eclipse.collections.impl.parallel.ParallelIterate.EXECUTOR_SERVICE:Ljava/util/concurrent/ExecutorService;
6: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEach:(Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;ILjava/util/concurrent/Executor;)V
7: aload 3
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 iterable Ljava/lang/Iterable<TT;>;
0 8 1 groupBy Lorg/eclipse/collections/api/block/function/Function<-TT;+TV;>;
0 8 2 function Lorg/eclipse/collections/api/block/function/primitive/FloatFunction<-TT;>;
1 8 3 result Lorg/eclipse/collections/impl/map/mutable/primitive/ObjectDoubleHashMap<TV;>;
Signature: <T:Ljava/lang/Object;V:Ljava/lang/Object;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/function/Function<-TT;+TV;>;Lorg/eclipse/collections/api/block/function/primitive/FloatFunction<-TT;>;)Lorg/eclipse/collections/api/map/primitive/ObjectDoubleMap<TV;>;
MethodParameters:
Name Flags
iterable
groupBy
function
public static <T, V> org.eclipse.collections.api.map.primitive.ObjectLongMap<V> sumByLong(java.lang.Iterable<T>, org.eclipse.collections.api.block.function.Function<? super T, ? extends V>, org.eclipse.collections.api.block.function.primitive.LongFunction<? super T>);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/primitive/LongFunction;)Lorg/eclipse/collections/api/map/primitive/ObjectLongMap;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=4, args_size=3
start local 0 start local 1 start local 2 0: invokestatic org.eclipse.collections.impl.map.mutable.primitive.ObjectLongHashMap.newMap:()Lorg/eclipse/collections/impl/map/mutable/primitive/ObjectLongHashMap;
astore 3
start local 3 1: aload 0
2: new org.eclipse.collections.impl.parallel.ParallelIterate$SumByLongProcedure
dup
aload 1
aload 2
invokespecial org.eclipse.collections.impl.parallel.ParallelIterate$SumByLongProcedure.<init>:(Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/primitive/LongFunction;)V
3: new org.eclipse.collections.impl.parallel.ParallelIterate$SumByLongCombiner
dup
aload 3
invokespecial org.eclipse.collections.impl.parallel.ParallelIterate$SumByLongCombiner.<init>:(Lorg/eclipse/collections/impl/map/mutable/primitive/ObjectLongHashMap;)V
4: sipush 10000
5: getstatic org.eclipse.collections.impl.parallel.ParallelIterate.EXECUTOR_SERVICE:Ljava/util/concurrent/ExecutorService;
6: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEach:(Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;ILjava/util/concurrent/Executor;)V
7: aload 3
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 iterable Ljava/lang/Iterable<TT;>;
0 8 1 groupBy Lorg/eclipse/collections/api/block/function/Function<-TT;+TV;>;
0 8 2 function Lorg/eclipse/collections/api/block/function/primitive/LongFunction<-TT;>;
1 8 3 result Lorg/eclipse/collections/impl/map/mutable/primitive/ObjectLongHashMap<TV;>;
Signature: <T:Ljava/lang/Object;V:Ljava/lang/Object;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/function/Function<-TT;+TV;>;Lorg/eclipse/collections/api/block/function/primitive/LongFunction<-TT;>;)Lorg/eclipse/collections/api/map/primitive/ObjectLongMap<TV;>;
MethodParameters:
Name Flags
iterable
groupBy
function
public static <T, V> org.eclipse.collections.api.map.primitive.ObjectLongMap<V> sumByInt(java.lang.Iterable<T>, org.eclipse.collections.api.block.function.Function<? super T, ? extends V>, org.eclipse.collections.api.block.function.primitive.IntFunction<? super T>);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/primitive/IntFunction;)Lorg/eclipse/collections/api/map/primitive/ObjectLongMap;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=4, args_size=3
start local 0 start local 1 start local 2 0: invokestatic org.eclipse.collections.impl.map.mutable.primitive.ObjectLongHashMap.newMap:()Lorg/eclipse/collections/impl/map/mutable/primitive/ObjectLongHashMap;
astore 3
start local 3 1: aload 0
2: new org.eclipse.collections.impl.parallel.ParallelIterate$SumByIntProcedure
dup
aload 1
aload 2
invokespecial org.eclipse.collections.impl.parallel.ParallelIterate$SumByIntProcedure.<init>:(Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/primitive/IntFunction;)V
3: new org.eclipse.collections.impl.parallel.ParallelIterate$SumByIntCombiner
dup
aload 3
invokespecial org.eclipse.collections.impl.parallel.ParallelIterate$SumByIntCombiner.<init>:(Lorg/eclipse/collections/impl/map/mutable/primitive/ObjectLongHashMap;)V
4: sipush 10000
5: getstatic org.eclipse.collections.impl.parallel.ParallelIterate.EXECUTOR_SERVICE:Ljava/util/concurrent/ExecutorService;
6: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEach:(Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;ILjava/util/concurrent/Executor;)V
7: aload 3
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 iterable Ljava/lang/Iterable<TT;>;
0 8 1 groupBy Lorg/eclipse/collections/api/block/function/Function<-TT;+TV;>;
0 8 2 function Lorg/eclipse/collections/api/block/function/primitive/IntFunction<-TT;>;
1 8 3 result Lorg/eclipse/collections/impl/map/mutable/primitive/ObjectLongHashMap<TV;>;
Signature: <T:Ljava/lang/Object;V:Ljava/lang/Object;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/function/Function<-TT;+TV;>;Lorg/eclipse/collections/api/block/function/primitive/IntFunction<-TT;>;)Lorg/eclipse/collections/api/map/primitive/ObjectLongMap<TV;>;
MethodParameters:
Name Flags
iterable
groupBy
function
public static <V, T> org.eclipse.collections.api.map.MutableMap<V, java.math.BigDecimal> sumByBigDecimal(java.lang.Iterable<T>, org.eclipse.collections.api.block.function.Function<? super T, ? extends V>, org.eclipse.collections.api.block.function.Function<? super T, java.math.BigDecimal>);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/Function;)Lorg/eclipse/collections/api/map/MutableMap;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=4, args_size=3
start local 0 start local 1 start local 2 0: invokestatic org.eclipse.collections.impl.map.mutable.UnifiedMap.newMap:()Lorg/eclipse/collections/impl/map/mutable/UnifiedMap;
astore 3
start local 3 1: aload 0
2: new org.eclipse.collections.impl.parallel.ParallelIterate$SumByBigDecimalProcedure
dup
aload 1
aload 2
invokespecial org.eclipse.collections.impl.parallel.ParallelIterate$SumByBigDecimalProcedure.<init>:(Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/Function;)V
3: new org.eclipse.collections.impl.parallel.ParallelIterate$SumByBigDecimalCombiner
dup
aload 3
invokespecial org.eclipse.collections.impl.parallel.ParallelIterate$SumByBigDecimalCombiner.<init>:(Lorg/eclipse/collections/api/map/MutableMap;)V
4: sipush 10000
5: getstatic org.eclipse.collections.impl.parallel.ParallelIterate.EXECUTOR_SERVICE:Ljava/util/concurrent/ExecutorService;
6: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEach:(Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;ILjava/util/concurrent/Executor;)V
7: aload 3
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 iterable Ljava/lang/Iterable<TT;>;
0 8 1 groupBy Lorg/eclipse/collections/api/block/function/Function<-TT;+TV;>;
0 8 2 function Lorg/eclipse/collections/api/block/function/Function<-TT;Ljava/math/BigDecimal;>;
1 8 3 result Lorg/eclipse/collections/api/map/MutableMap<TV;Ljava/math/BigDecimal;>;
Signature: <V:Ljava/lang/Object;T:Ljava/lang/Object;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/function/Function<-TT;+TV;>;Lorg/eclipse/collections/api/block/function/Function<-TT;Ljava/math/BigDecimal;>;)Lorg/eclipse/collections/api/map/MutableMap<TV;Ljava/math/BigDecimal;>;
MethodParameters:
Name Flags
iterable
groupBy
function
public static <V, T> org.eclipse.collections.api.map.MutableMap<V, java.math.BigInteger> sumByBigInteger(java.lang.Iterable<T>, org.eclipse.collections.api.block.function.Function<? super T, ? extends V>, org.eclipse.collections.api.block.function.Function<? super T, java.math.BigInteger>);
descriptor: (Ljava/lang/Iterable;Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/Function;)Lorg/eclipse/collections/api/map/MutableMap;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=4, args_size=3
start local 0 start local 1 start local 2 0: invokestatic org.eclipse.collections.impl.map.mutable.UnifiedMap.newMap:()Lorg/eclipse/collections/impl/map/mutable/UnifiedMap;
astore 3
start local 3 1: aload 0
2: new org.eclipse.collections.impl.parallel.ParallelIterate$SumByBigIntegerProcedure
dup
aload 1
aload 2
invokespecial org.eclipse.collections.impl.parallel.ParallelIterate$SumByBigIntegerProcedure.<init>:(Lorg/eclipse/collections/api/block/function/Function;Lorg/eclipse/collections/api/block/function/Function;)V
3: new org.eclipse.collections.impl.parallel.ParallelIterate$SumByBigIntegerCombiner
dup
aload 3
invokespecial org.eclipse.collections.impl.parallel.ParallelIterate$SumByBigIntegerCombiner.<init>:(Lorg/eclipse/collections/api/map/MutableMap;)V
4: sipush 10000
5: getstatic org.eclipse.collections.impl.parallel.ParallelIterate.EXECUTOR_SERVICE:Ljava/util/concurrent/ExecutorService;
6: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.forEach:(Ljava/lang/Iterable;Lorg/eclipse/collections/impl/parallel/ProcedureFactory;Lorg/eclipse/collections/impl/parallel/Combiner;ILjava/util/concurrent/Executor;)V
7: aload 3
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 iterable Ljava/lang/Iterable<TT;>;
0 8 1 groupBy Lorg/eclipse/collections/api/block/function/Function<-TT;+TV;>;
0 8 2 function Lorg/eclipse/collections/api/block/function/Function<-TT;Ljava/math/BigInteger;>;
1 8 3 result Lorg/eclipse/collections/api/map/MutableMap<TV;Ljava/math/BigInteger;>;
Signature: <V:Ljava/lang/Object;T:Ljava/lang/Object;>(Ljava/lang/Iterable<TT;>;Lorg/eclipse/collections/api/block/function/Function<-TT;+TV;>;Lorg/eclipse/collections/api/block/function/Function<-TT;Ljava/math/BigInteger;>;)Lorg/eclipse/collections/api/map/MutableMap<TV;Ljava/math/BigInteger;>;
MethodParameters:
Name Flags
iterable
groupBy
function
public static java.util.concurrent.ExecutorService newPooledExecutor(int, java.lang.String, boolean);
descriptor: (ILjava/lang/String;Z)Ljava/util/concurrent/ExecutorService;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=12, locals=3, args_size=3
start local 0 start local 1 start local 2 0: new java.util.concurrent.ThreadPoolExecutor
dup
1: iload 0
2: iload 0
3: lconst_0
4: getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
5: new java.util.concurrent.SynchronousQueue
dup
invokespecial java.util.concurrent.SynchronousQueue.<init>:()V
6: new org.eclipse.collections.impl.parallel.CollectionsThreadFactory
dup
aload 1
iload 2
invokespecial org.eclipse.collections.impl.parallel.CollectionsThreadFactory.<init>:(Ljava/lang/String;Z)V
7: new java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy
dup
invokespecial java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy.<init>:()V
8: invokespecial java.util.concurrent.ThreadPoolExecutor.<init>:(IIJLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/BlockingQueue;Ljava/util/concurrent/ThreadFactory;Ljava/util/concurrent/RejectedExecutionHandler;)V
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 newPoolSize I
0 9 1 poolName Ljava/lang/String;
0 9 2 useDaemonThreads Z
MethodParameters:
Name Flags
newPoolSize
poolName
useDaemonThreads
public static java.util.concurrent.ExecutorService newPooledExecutor(java.lang.String, boolean);
descriptor: (Ljava/lang/String;Z)Ljava/util/concurrent/ExecutorService;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.getDefaultMaxThreadPoolSize:()I
aload 0
iload 1
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.newPooledExecutor:(ILjava/lang/String;Z)Ljava/util/concurrent/ExecutorService;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 poolName Ljava/lang/String;
0 1 1 useDaemonThreads Z
MethodParameters:
Name Flags
poolName
useDaemonThreads
public static int getDefaultTaskCount();
descriptor: ()I
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.getDefaultMaxThreadPoolSize:()I
invokestatic org.eclipse.collections.impl.parallel.ParallelIterate.getTaskRatio:()I
imul
ireturn
LocalVariableTable:
Start End Slot Name Signature
public static int getDefaultMaxThreadPoolSize();
descriptor: ()I
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: getstatic org.eclipse.collections.impl.parallel.ParallelIterate.AVAILABLE_PROCESSORS:I
iconst_1
iadd
bipush 100
invokestatic java.lang.Math.min:(II)I
ireturn
LocalVariableTable:
Start End Slot Name Signature
public static int getTaskRatio();
descriptor: ()I
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: iconst_2
ireturn
LocalVariableTable:
Start End Slot Name Signature
}
SourceFile: "ParallelIterate.java"
NestMembers:
org.eclipse.collections.impl.parallel.ParallelIterate$SumByBigDecimalCombiner org.eclipse.collections.impl.parallel.ParallelIterate$SumByBigDecimalProcedure org.eclipse.collections.impl.parallel.ParallelIterate$SumByBigIntegerCombiner org.eclipse.collections.impl.parallel.ParallelIterate$SumByBigIntegerProcedure org.eclipse.collections.impl.parallel.ParallelIterate$SumByDoubleCombiner org.eclipse.collections.impl.parallel.ParallelIterate$SumByDoubleProcedure org.eclipse.collections.impl.parallel.ParallelIterate$SumByFloatCombiner org.eclipse.collections.impl.parallel.ParallelIterate$SumByFloatProcedure org.eclipse.collections.impl.parallel.ParallelIterate$SumByIntCombiner org.eclipse.collections.impl.parallel.ParallelIterate$SumByIntProcedure org.eclipse.collections.impl.parallel.ParallelIterate$SumByLongCombiner org.eclipse.collections.impl.parallel.ParallelIterate$SumByLongProcedure
InnerClasses:
public CallerRunsPolicy = java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy of java.util.concurrent.ThreadPoolExecutor
private final SumByBigDecimalCombiner = org.eclipse.collections.impl.parallel.ParallelIterate$SumByBigDecimalCombiner of org.eclipse.collections.impl.parallel.ParallelIterate
private final SumByBigDecimalProcedure = org.eclipse.collections.impl.parallel.ParallelIterate$SumByBigDecimalProcedure of org.eclipse.collections.impl.parallel.ParallelIterate
private final SumByBigIntegerCombiner = org.eclipse.collections.impl.parallel.ParallelIterate$SumByBigIntegerCombiner of org.eclipse.collections.impl.parallel.ParallelIterate
private final SumByBigIntegerProcedure = org.eclipse.collections.impl.parallel.ParallelIterate$SumByBigIntegerProcedure of org.eclipse.collections.impl.parallel.ParallelIterate
private final SumByDoubleCombiner = org.eclipse.collections.impl.parallel.ParallelIterate$SumByDoubleCombiner of org.eclipse.collections.impl.parallel.ParallelIterate
private final SumByDoubleProcedure = org.eclipse.collections.impl.parallel.ParallelIterate$SumByDoubleProcedure of org.eclipse.collections.impl.parallel.ParallelIterate
private final SumByFloatCombiner = org.eclipse.collections.impl.parallel.ParallelIterate$SumByFloatCombiner of org.eclipse.collections.impl.parallel.ParallelIterate
private final SumByFloatProcedure = org.eclipse.collections.impl.parallel.ParallelIterate$SumByFloatProcedure of org.eclipse.collections.impl.parallel.ParallelIterate
private final SumByIntCombiner = org.eclipse.collections.impl.parallel.ParallelIterate$SumByIntCombiner of org.eclipse.collections.impl.parallel.ParallelIterate
private final SumByIntProcedure = org.eclipse.collections.impl.parallel.ParallelIterate$SumByIntProcedure of org.eclipse.collections.impl.parallel.ParallelIterate
private final SumByLongCombiner = org.eclipse.collections.impl.parallel.ParallelIterate$SumByLongCombiner of org.eclipse.collections.impl.parallel.ParallelIterate
private final SumByLongProcedure = org.eclipse.collections.impl.parallel.ParallelIterate$SumByLongProcedure of org.eclipse.collections.impl.parallel.ParallelIterate