Kactoos

kactoos-jvm / nnl.rocks.kactoos.scalar / AndInThreads

AndInThreads

class AndInThreads : Scalar<Boolean>

Logical conjunction, in multiple threads.

This class can be effectively used to iterate through a collection, just like java.util.stream.Stream.forEach works:

new AndInThreads(
new IterableOf("Mary", "John", "William", "Napkin"),
name -> System.out.printf("The name: %s\n", name)
).value();

There is no thread-safety guarantee.

Parameters

service - Executable service to run thread in

iterable - The iterable

shut - Shut it down

See Also

IoCheckedScalar

Since 0.25

Constructors

Name

Summary

<init>

AndInThreads(vararg src: KScalar<Boolean>) AndInThreads(vararg src: Scalar<Boolean>) AndInThreads(src: Iterable<KScalar<Boolean>>)AndInThreads(svc: ExecutorService, vararg src: KScalar<Boolean>) AndInThreads(svc: ExecutorService, src: Iterable<KScalar<Boolean>>) Ctor.AndInThreads(service: ExecutorService, iterable: Iterable<KScalar<Boolean>>, shut: Boolean) Logical conjunction, in multiple threads.

Functions

Name	Summary
invoke	fun invoke(): Boolean Get value of this Scalar

Companion Object Functions

Name

Summary

invoke

operator fun <X : Any> invoke(proc: Proc<X>, vararg src: X): AndInThreads operator fun <X : Any> invoke(func: Func<X, Boolean>, vararg src: X): AndInThreads operator fun <X : Any> invoke(proc: Proc<X>, src: Iterable<X>): AndInThreads operator fun <X : Any> invoke(func: Func<X, Boolean>, src: Iterable<X>): AndInThreads operator fun <X : Any> invoke(svc: ExecutorService, proc: Proc<X>, vararg src: X): AndInThreads operator fun <X : Any> invoke(svc: ExecutorService, func: Func<X, Boolean>, vararg src: X): AndInThreadsoperator fun <X : Any> invoke(svc: ExecutorService, proc: Proc<X>, src: Iterable<X>): AndInThreads operator fun <X : Any> invoke(svc: ExecutorService, func: Func<X, Boolean>, src: Iterable<X>): AndInThreads Ctor.

This site is open source. Improve this page.