kactoos-jvm / nnl.rocks.kactoos.scalar / 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.
service
- Executable service to run thread in
iterable
- The iterable
shut
- Shut it down
See Also
Since 0.25
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. |
Name | Summary |
---|---|
invoke | fun invoke(): Boolean Get value of this Scalar |
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 ): AndInThreads operator 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. |