com_baeldung_reactor_introduction_ReactorIntegrationTest_java
reactor.core.publisher.FluxZip
 -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.concurrent.atomic.AtomicLongFieldUpdater.get(java.lang.Object): long -> java.util.concurrent.atomic.AtomicLongFieldUpdater.compareAndSet(java.lang.Object,long,long): boolean -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.getAndIncrement(java.lang.Object): int -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.addAndGet(java.lang.Object,int): int -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.function.Consumer.accept(java.lang.Object): void -> java.lang.StringBuilder.append(java.lang.String): java.lang.StringBuilder -> java.lang.Object.getClass(): java.lang.Class -> java.lang.Class.getCanonicalName(): java.lang.String -> java.lang.Class.getPackage(): java.lang.Package -> java.lang.Package.getName(): java.lang.String -> java.lang.StringBuilder.append(java.lang.String): java.lang.StringBuilder -> java.lang.StringBuilder.append(java.lang.String): java.lang.StringBuilder -> java.lang.StringBuilder.toString(): java.lang.String -> java.lang.String.replaceFirst(java.lang.String,java.lang.String): java.lang.String -> java.lang.StringBuilder.append(java.lang.String): java.lang.StringBuilder -> java.lang.StringBuilder.toString(): java.lang.String -> java.util.concurrent.atomic.AtomicBoolean.get(): boolean -> java.lang.ThreadLocal.get(): java.lang.Object -> java.lang.Boolean.equals(java.lang.Object): boolean -> java.lang.ThreadLocal.set(java.lang.Object): void -> java.util.concurrent.atomic.AtomicBoolean.get(): boolean -> java.text.SimpleDateFormat.format(java.util.Date): java.lang.String -> java.lang.String.getBytes(): byte[] -> java.util.concurrent.locks.ReentrantLock.lock(): void -> java.io.OutputStream.write(byte[]): void -> java.io.PrintStream.write(byte[]): void -> java.io.OutputStream.flush(): void -> java.io.PrintStream.flush(): void -> java.util.concurrent.locks.ReentrantLock.unlock(): void -> java.lang.ThreadLocal.set(java.lang.Object): void -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.concurrent.atomic.AtomicReferenceFieldUpdater.get(java.lang.Object): java.lang.Object -> java.util.concurrent.atomic.AtomicReferenceFieldUpdater.compareAndSet(java.lang.Object,java.lang.Object,java.lang.Object): boolean -> java.util.function.Supplier.get(): java.lang.Object -> java.lang.Integer.numberOfLeadingZeros(int): int -> java.util.function.Function.apply(java.lang.Object): java.lang.Object -> java.util.function.LongConsumer.accept(long): void -> java.lang.Long.valueOf(long): java.lang.Long -> java.util.concurrent.atomic.AtomicBoolean.get(): boolean -> java.lang.ThreadLocal.get(): java.lang.Object -> java.lang.Boolean.equals(java.lang.Object): boolean -> java.lang.ThreadLocal.set(java.lang.Object): void -> java.util.concurrent.atomic.AtomicBoolean.get(): boolean -> java.text.SimpleDateFormat.format(java.util.Date): java.lang.String -> java.lang.String.getBytes(): byte[] -> java.util.concurrent.locks.ReentrantLock.lock(): void -> java.io.OutputStream.write(byte[]): void -> java.io.PrintStream.write(byte[]): void -> java.io.OutputStream.flush(): void -> java.io.PrintStream.flush(): void -> java.util.concurrent.locks.ReentrantLock.unlock(): void -> java.lang.ThreadLocal.set(java.lang.Object): void -> java.util.concurrent.atomic.AtomicLongFieldUpdater.get(java.lang.Object): long -> java.util.concurrent.atomic.AtomicLongFieldUpdater.compareAndSet(java.lang.Object,long,long): boolean -> java.util.function.Consumer.accept(java.lang.Object): void -> java.util.concurrent.atomic.AtomicBoolean.get(): boolean -> java.lang.ThreadLocal.get(): java.lang.Object -> java.lang.Boolean.equals(java.lang.Object): boolean -> java.lang.ThreadLocal.set(java.lang.Object): void -> java.util.concurrent.atomic.AtomicBoolean.get(): boolean -> java.text.SimpleDateFormat.format(java.util.Date): java.lang.String -> java.lang.String.getBytes(): byte[] -> java.util.concurrent.locks.ReentrantLock.lock(): void -> java.io.OutputStream.write(byte[]): void -> java.io.PrintStream.write(byte[]): void -> java.io.OutputStream.flush(): void -> java.io.PrintStream.flush(): void -> java.util.concurrent.locks.ReentrantLock.unlock(): void -> java.lang.ThreadLocal.set(java.lang.Object): void -> java.util.function.Function.apply(java.lang.Object): java.lang.Object -> java.lang.Integer.intValue(): int -> java.lang.Integer.valueOf(int): java.lang.Integer -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Queue.offer(java.lang.Object): boolean -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.concurrent.atomic.AtomicLongFieldUpdater.lazySet(java.lang.Object,long): void -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.getAndIncrement(java.lang.Object): int -> java.util.Queue.poll(): java.lang.Object -> java.util.concurrent.atomic.AtomicLongFieldUpdater.lazySet(java.lang.Object,long): void -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.addAndGet(java.lang.Object,int): int -> java.util.function.Consumer.accept(java.lang.Object): void -> java.util.concurrent.atomic.AtomicBoolean.get(): boolean -> java.lang.ThreadLocal.get(): java.lang.Object -> java.lang.Boolean.equals(java.lang.Object): boolean -> java.lang.ThreadLocal.set(java.lang.Object): void -> java.util.concurrent.atomic.AtomicBoolean.get(): boolean -> java.text.SimpleDateFormat.format(java.util.Date): java.lang.String -> java.lang.String.getBytes(): byte[] -> java.util.concurrent.locks.ReentrantLock.lock(): void -> java.io.OutputStream.write(byte[]): void -> java.io.PrintStream.write(byte[]): void -> java.io.OutputStream.flush(): void -> java.io.PrintStream.flush(): void -> java.util.concurrent.locks.ReentrantLock.unlock(): void -> java.lang.ThreadLocal.set(java.lang.Object): void -> java.util.function.Function.apply(java.lang.Object): java.lang.Object -> java.lang.Integer.intValue(): int -> java.lang.Integer.valueOf(int): java.lang.Integer -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Queue.offer(java.lang.Object): boolean -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.concurrent.atomic.AtomicLongFieldUpdater.lazySet(java.lang.Object,long): void -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.getAndIncrement(java.lang.Object): int -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.addAndGet(java.lang.Object,int): int -> java.util.function.Consumer.accept(java.lang.Object): void -> java.util.concurrent.atomic.AtomicBoolean.get(): boolean -> java.lang.ThreadLocal.get(): java.lang.Object -> java.lang.Boolean.equals(java.lang.Object): boolean -> java.lang.ThreadLocal.set(java.lang.Object): void -> java.util.concurrent.atomic.AtomicBoolean.get(): boolean -> java.text.SimpleDateFormat.format(java.util.Date): java.lang.String -> java.lang.String.getBytes(): byte[] -> java.util.concurrent.locks.ReentrantLock.lock(): void -> java.io.OutputStream.write(byte[]): void -> java.io.PrintStream.write(byte[]): void -> java.io.OutputStream.flush(): void -> java.io.PrintStream.flush(): void -> java.util.concurrent.locks.ReentrantLock.unlock(): void -> java.lang.ThreadLocal.set(java.lang.Object): void -> java.util.function.Function.apply(java.lang.Object): java.lang.Object -> java.lang.Integer.intValue(): int -> java.lang.Integer.valueOf(int): java.lang.Integer -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Queue.offer(java.lang.Object): boolean -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.concurrent.atomic.AtomicLongFieldUpdater.lazySet(java.lang.Object,long): void -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.getAndIncrement(java.lang.Object): int -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.addAndGet(java.lang.Object,int): int -> java.util.function.Consumer.accept(java.lang.Object): void -> java.util.concurrent.atomic.AtomicBoolean.get(): boolean -> java.lang.ThreadLocal.get(): java.lang.Object -> java.lang.Boolean.equals(java.lang.Object): boolean -> java.lang.ThreadLocal.set(java.lang.Object): void -> java.util.concurrent.atomic.AtomicBoolean.get(): boolean -> java.text.SimpleDateFormat.format(java.util.Date): java.lang.String -> java.lang.String.getBytes(): byte[] -> java.util.concurrent.locks.ReentrantLock.lock(): void -> java.io.OutputStream.write(byte[]): void -> java.io.PrintStream.write(byte[]): void -> java.io.OutputStream.flush(): void -> java.io.PrintStream.flush(): void -> java.util.concurrent.locks.ReentrantLock.unlock(): void -> java.lang.ThreadLocal.set(java.lang.Object): void -> java.util.function.Function.apply(java.lang.Object): java.lang.Object -> java.lang.Integer.intValue(): int -> java.lang.Integer.valueOf(int): java.lang.Integer -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Queue.offer(java.lang.Object): boolean -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.concurrent.atomic.AtomicLongFieldUpdater.lazySet(java.lang.Object,long): void -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.getAndIncrement(java.lang.Object): int -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.addAndGet(java.lang.Object,int): int -> java.lang.Runnable.run(): void -> java.util.concurrent.atomic.AtomicBoolean.get(): boolean -> java.lang.ThreadLocal.get(): java.lang.Object -> java.lang.Boolean.equals(java.lang.Object): boolean -> java.lang.ThreadLocal.set(java.lang.Object): void -> java.util.concurrent.atomic.AtomicBoolean.get(): boolean -> java.text.SimpleDateFormat.format(java.util.Date): java.lang.String -> java.lang.String.getBytes(): byte[] -> java.util.concurrent.locks.ReentrantLock.lock(): void -> java.io.OutputStream.write(byte[]): void -> java.io.PrintStream.write(byte[]): void -> java.io.OutputStream.flush(): void -> java.io.PrintStream.flush(): void -> java.util.concurrent.locks.ReentrantLock.unlock(): void -> java.lang.ThreadLocal.set(java.lang.Object): void -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.getAndIncrement(java.lang.Object): int -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.addAndGet(java.lang.Object,int): int -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.function.Consumer.accept(java.lang.Object): void -> java.lang.StringBuilder.append(java.lang.String): java.lang.StringBuilder -> java.lang.Object.getClass(): java.lang.Class -> java.lang.Class.getCanonicalName(): java.lang.String -> java.lang.Class.getPackage(): java.lang.Package -> java.lang.Package.getName(): java.lang.String -> java.lang.StringBuilder.append(java.lang.String): java.lang.StringBuilder -> java.lang.StringBuilder.append(java.lang.String): java.lang.StringBuilder -> java.lang.StringBuilder.toString(): java.lang.String -> java.lang.String.replaceFirst(java.lang.String,java.lang.String): java.lang.String -> java.lang.StringBuilder.append(java.lang.String): java.lang.StringBuilder -> java.lang.StringBuilder.toString(): java.lang.String -> java.util.concurrent.atomic.AtomicBoolean.get(): boolean -> java.lang.ThreadLocal.get(): java.lang.Object -> java.lang.Boolean.equals(java.lang.Object): boolean -> java.lang.ThreadLocal.set(java.lang.Object): void -> java.util.concurrent.atomic.AtomicBoolean.get(): boolean -> java.text.SimpleDateFormat.format(java.util.Date): java.lang.String -> java.lang.String.getBytes(): byte[] -> java.util.concurrent.locks.ReentrantLock.lock(): void -> java.io.OutputStream.write(byte[]): void -> java.io.PrintStream.write(byte[]): void -> java.io.OutputStream.flush(): void -> java.io.PrintStream.flush(): void -> java.util.concurrent.locks.ReentrantLock.unlock(): void -> java.lang.ThreadLocal.set(java.lang.Object): void -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.concurrent.atomic.AtomicReferenceFieldUpdater.get(java.lang.Object): java.lang.Object -> java.util.concurrent.atomic.AtomicReferenceFieldUpdater.compareAndSet(java.lang.Object,java.lang.Object,java.lang.Object): boolean -> java.util.function.Supplier.get(): java.lang.Object -> java.lang.Integer.numberOfLeadingZeros(int): int -> java.util.function.Function.apply(java.lang.Object): java.lang.Object -> java.util.function.LongConsumer.accept(long): void -> java.lang.Long.valueOf(long): java.lang.Long -> java.util.concurrent.atomic.AtomicBoolean.get(): boolean -> java.lang.ThreadLocal.get(): java.lang.Object -> java.lang.Boolean.equals(java.lang.Object): boolean -> java.lang.ThreadLocal.set(java.lang.Object): void -> java.util.concurrent.atomic.AtomicBoolean.get(): boolean -> java.text.SimpleDateFormat.format(java.util.Date): java.lang.String -> java.lang.String.getBytes(): byte[] -> java.util.concurrent.locks.ReentrantLock.lock(): void -> java.io.OutputStream.write(byte[]): void -> java.io.PrintStream.write(byte[]): void -> java.io.OutputStream.flush(): void -> java.io.PrintStream.flush(): void -> java.util.concurrent.locks.ReentrantLock.unlock(): void -> java.lang.ThreadLocal.set(java.lang.Object): void -> java.util.concurrent.atomic.AtomicLongFieldUpdater.get(java.lang.Object): long -> java.util.concurrent.atomic.AtomicLongFieldUpdater.compareAndSet(java.lang.Object,long,long): boolean -> java.lang.Integer.valueOf(int): java.lang.Integer -> java.util.function.Consumer.accept(java.lang.Object): void -> java.util.concurrent.atomic.AtomicBoolean.get(): boolean -> java.lang.ThreadLocal.get(): java.lang.Object -> java.lang.Boolean.equals(java.lang.Object): boolean -> java.lang.ThreadLocal.set(java.lang.Object): void -> java.util.concurrent.atomic.AtomicBoolean.get(): boolean -> java.text.SimpleDateFormat.format(java.util.Date): java.lang.String -> java.lang.String.getBytes(): byte[] -> java.util.concurrent.locks.ReentrantLock.lock(): void -> java.io.OutputStream.write(byte[]): void -> java.io.PrintStream.write(byte[]): void -> java.io.OutputStream.flush(): void -> java.io.PrintStream.flush(): void -> java.util.concurrent.locks.ReentrantLock.unlock(): void -> java.lang.ThreadLocal.set(java.lang.Object): void -> java.util.Queue.offer(java.lang.Object): boolean -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.concurrent.atomic.AtomicLongFieldUpdater.lazySet(java.lang.Object,long): void -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.getAndIncrement(java.lang.Object): int -> java.util.Queue.poll(): java.lang.Object -> java.util.concurrent.atomic.AtomicLongFieldUpdater.lazySet(java.lang.Object,long): void -> java.lang.Object[].clone(): java.lang.Object -> java.util.function.Function.apply(java.lang.Object): java.lang.Object -> java.util.function.BiFunction.apply(java.lang.Object,java.lang.Object): java.lang.Object -> java.lang.String.format(java.lang.String,java.lang.Object[]): java.lang.String -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.function.Consumer.accept(java.lang.Object): void -> java.util.Arrays.fill(java.lang.Object[],java.lang.Object): void -> java.util.Queue.poll(): java.lang.Object -> java.util.concurrent.atomic.AtomicLongFieldUpdater.lazySet(java.lang.Object,long): void -> java.util.Queue.poll(): java.lang.Object -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.addAndGet(java.lang.Object,int): int -> java.lang.Integer.valueOf(int): java.lang.Integer -> java.util.function.Consumer.accept(java.lang.Object): void -> java.util.concurrent.atomic.AtomicBoolean.get(): boolean -> java.lang.ThreadLocal.get(): java.lang.Object -> java.lang.Boolean.equals(java.lang.Object): boolean -> java.lang.ThreadLocal.set(java.lang.Object): void -> java.util.concurrent.atomic.AtomicBoolean.get(): boolean -> java.text.SimpleDateFormat.format(java.util.Date): java.lang.String -> java.lang.String.getBytes(): byte[] -> java.util.concurrent.locks.ReentrantLock.lock(): void -> java.io.OutputStream.write(byte[]): void -> java.io.PrintStream.write(byte[]): void -> java.io.OutputStream.flush(): void -> java.io.PrintStream.flush(): void -> java.util.concurrent.locks.ReentrantLock.unlock(): void -> java.lang.ThreadLocal.set(java.lang.Object): void -> java.util.Queue.offer(java.lang.Object): boolean -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.concurrent.atomic.AtomicLongFieldUpdater.lazySet(java.lang.Object,long): void -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.getAndIncrement(java.lang.Object): int -> java.util.Queue.poll(): java.lang.Object -> java.util.concurrent.atomic.AtomicLongFieldUpdater.lazySet(java.lang.Object,long): void -> java.lang.Object[].clone(): java.lang.Object -> java.util.function.Function.apply(java.lang.Object): java.lang.Object -> java.util.function.BiFunction.apply(java.lang.Object,java.lang.Object): java.lang.Object -> java.lang.String.format(java.lang.String,java.lang.Object[]): java.lang.String -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.function.Consumer.accept(java.lang.Object): void -> java.util.Arrays.fill(java.lang.Object[],java.lang.Object): void -> java.util.Queue.poll(): java.lang.Object -> java.util.concurrent.atomic.AtomicLongFieldUpdater.lazySet(java.lang.Object,long): void -> java.util.Queue.poll(): java.lang.Object -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.addAndGet(java.lang.Object,int): int -> java.lang.Integer.valueOf(int): java.lang.Integer -> java.util.function.Consumer.accept(java.lang.Object): void -> java.util.concurrent.atomic.AtomicBoolean.get(): boolean -> java.lang.ThreadLocal.get(): java.lang.Object -> java.lang.Boolean.equals(java.lang.Object): boolean -> java.lang.ThreadLocal.set(java.lang.Object): void -> java.util.concurrent.atomic.AtomicBoolean.get(): boolean -> java.text.SimpleDateFormat.format(java.util.Date): java.lang.String -> java.lang.String.getBytes(): byte[] -> java.util.concurrent.locks.ReentrantLock.lock(): void -> java.io.OutputStream.write(byte[]): void -> java.io.PrintStream.write(byte[]): void -> java.io.OutputStream.flush(): void -> java.io.PrintStream.flush(): void -> java.util.concurrent.locks.ReentrantLock.unlock(): void -> java.lang.ThreadLocal.set(java.lang.Object): void -> java.util.Queue.offer(java.lang.Object): boolean -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.concurrent.atomic.AtomicLongFieldUpdater.lazySet(java.lang.Object,long): void -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.getAndIncrement(java.lang.Object): int -> java.util.Queue.poll(): java.lang.Object -> java.util.concurrent.atomic.AtomicLongFieldUpdater.lazySet(java.lang.Object,long): void -> java.lang.Object[].clone(): java.lang.Object -> java.util.function.Function.apply(java.lang.Object): java.lang.Object -> java.util.function.BiFunction.apply(java.lang.Object,java.lang.Object): java.lang.Object -> java.lang.String.format(java.lang.String,java.lang.Object[]): java.lang.String -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.function.Consumer.accept(java.lang.Object): void -> java.util.Arrays.fill(java.lang.Object[],java.lang.Object): void -> java.util.Queue.poll(): java.lang.Object -> java.util.concurrent.atomic.AtomicLongFieldUpdater.lazySet(java.lang.Object,long): void -> java.util.Queue.poll(): java.lang.Object -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.addAndGet(java.lang.Object,int): int -> java.lang.Integer.valueOf(int): java.lang.Integer -> java.util.function.Consumer.accept(java.lang.Object): void -> java.util.concurrent.atomic.AtomicBoolean.get(): boolean -> java.lang.ThreadLocal.get(): java.lang.Object -> java.lang.Boolean.equals(java.lang.Object): boolean -> java.lang.ThreadLocal.set(java.lang.Object): void -> java.util.concurrent.atomic.AtomicBoolean.get(): boolean -> java.text.SimpleDateFormat.format(java.util.Date): java.lang.String -> java.lang.String.getBytes(): byte[] -> java.util.concurrent.locks.ReentrantLock.lock(): void -> java.io.OutputStream.write(byte[]): void -> java.io.PrintStream.write(byte[]): void -> java.io.OutputStream.flush(): void -> java.io.PrintStream.flush(): void -> java.util.concurrent.locks.ReentrantLock.unlock(): void -> java.lang.ThreadLocal.set(java.lang.Object): void -> java.util.Queue.offer(java.lang.Object): boolean -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.concurrent.atomic.AtomicLongFieldUpdater.lazySet(java.lang.Object,long): void -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.getAndIncrement(java.lang.Object): int -> java.util.Queue.poll(): java.lang.Object -> java.util.concurrent.atomic.AtomicLongFieldUpdater.lazySet(java.lang.Object,long): void -> java.lang.Object[].clone(): java.lang.Object -> java.util.function.Function.apply(java.lang.Object): java.lang.Object -> java.util.function.BiFunction.apply(java.lang.Object,java.lang.Object): java.lang.Object -> java.lang.String.format(java.lang.String,java.lang.Object[]): java.lang.String -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.function.Consumer.accept(java.lang.Object): void -> java.util.Arrays.fill(java.lang.Object[],java.lang.Object): void -> java.util.Queue.poll(): java.lang.Object -> java.util.concurrent.atomic.AtomicReferenceFieldUpdater.get(java.lang.Object): java.lang.Object -> java.util.concurrent.atomic.AtomicReferenceFieldUpdater.getAndSet(java.lang.Object,java.lang.Object): java.lang.Object -> java.lang.Runnable.run(): void -> java.util.concurrent.atomic.AtomicBoolean.get(): boolean -> java.lang.ThreadLocal.get(): java.lang.Object -> java.lang.Boolean.equals(java.lang.Object): boolean -> java.lang.ThreadLocal.set(java.lang.Object): void -> java.util.concurrent.atomic.AtomicBoolean.get(): boolean -> java.text.SimpleDateFormat.format(java.util.Date): java.lang.String -> java.lang.String.getBytes(): byte[] -> java.util.concurrent.locks.ReentrantLock.lock(): void -> java.io.OutputStream.write(byte[]): void -> java.io.PrintStream.write(byte[]): void -> java.io.OutputStream.flush(): void -> java.io.PrintStream.flush(): void -> java.util.concurrent.locks.ReentrantLock.unlock(): void -> java.lang.ThreadLocal.set(java.lang.Object): void -> java.util.concurrent.atomic.AtomicReferenceFieldUpdater.get(java.lang.Object): java.lang.Object -> java.util.concurrent.atomic.AtomicReferenceFieldUpdater.getAndSet(java.lang.Object,java.lang.Object): java.lang.Object -> java.lang.Runnable.run(): void -> java.util.concurrent.atomic.AtomicBoolean.get(): boolean -> java.lang.ThreadLocal.get(): java.lang.Object -> java.lang.Boolean.equals(java.lang.Object): boolean -> java.lang.ThreadLocal.set(java.lang.Object): void -> java.util.concurrent.atomic.AtomicBoolean.get(): boolean -> java.text.SimpleDateFormat.format(java.util.Date): java.lang.String -> java.lang.String.getBytes(): byte[] -> java.util.concurrent.locks.ReentrantLock.lock(): void -> java.io.OutputStream.write(byte[]): void -> java.io.PrintStream.write(byte[]): void -> java.io.OutputStream.flush(): void -> java.io.PrintStream.flush(): void -> java.util.concurrent.locks.ReentrantLock.unlock(): void -> java.lang.ThreadLocal.set(java.lang.Object): void -> java.util.concurrent.atomic.AtomicReferenceFieldUpdater.getAndSet(java.lang.Object,java.lang.Object): java.lang.Object