/* package whatever; // don't place package name! */
import java.util.stream.Stream;
/* Name of the class has to be "Main" only if the class is public. */
class Ideone
{
{
Stream.of(1, 2).parallel()
.
peek(x
-> System.
out.
println("processing "+x
+" in "+Thread.
currentThread())) .
forEach(System.
out::println
); }
}
LyogcGFja2FnZSB3aGF0ZXZlcjsgLy8gZG9uJ3QgcGxhY2UgcGFja2FnZSBuYW1lISAqLwoKaW1wb3J0IGphdmEudXRpbC5zdHJlYW0uU3RyZWFtOwoKLyogTmFtZSBvZiB0aGUgY2xhc3MgaGFzIHRvIGJlICJNYWluIiBvbmx5IGlmIHRoZSBjbGFzcyBpcyBwdWJsaWMuICovCmNsYXNzIElkZW9uZQp7CglwdWJsaWMgc3RhdGljIHZvaWQgbWFpbiAoU3RyaW5nW10gYXJncykgdGhyb3dzIGphdmEubGFuZy5FeGNlcHRpb24KCXsKICAgICAgICBTdHJlYW0ub2YoMSwgMikucGFyYWxsZWwoKQogICAgICAgICAgICAgIC5wZWVrKHggLT4gU3lzdGVtLm91dC5wcmludGxuKCJwcm9jZXNzaW5nICIreCsiIGluICIrVGhyZWFkLmN1cnJlbnRUaHJlYWQoKSkpCiAgICAgICAgICAgICAgLmZvckVhY2goU3lzdGVtLm91dDo6cHJpbnRsbik7Cgl9Cn0=