假设我有一个无限的流:
Stream<Socket> stream = Stream.generate(() -> {
try {
return serverSocket.accept();
} catch (IOException e) {
throw new RuntimeException(e);
}
});
我希望能够像这样使用它:
stream.forEach(socket -> {
new Thread(() -> {
socket.getOutputStream().write("Hi there, client.");
});
});
但这似乎不起作用,这可能是因为我误解了 Java 8 Streams 的一个关键方面。我做错了什么?
最佳答案
@Andres Riofrio 答案的变体:
stream
.<Runnable>map(socket -> () ->
socket
.getOutputStream()
.write("Hi there, client.")
) // create a Runnable that writes a string to the socket's output stream
.map(Thread::new) // transform each Runnable into a Thread
.forEach(Thread::start) // start each Thread
;
关于java - 如何使用无限的java.util.stream.Stream?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/23573274/