single thread executor

[Miguel Ping]

Hi all,

I was experimenting with single thread executor and loom, and I was
expecting that if I have two tasks where the first call goes through
Socket.read, loom would schedule the second one. I'm pretty sure I'm doing
something wrong.

Here's the output I got (I was expecting "Hello world" to appear before
"Connected!"; the program only concludes after I Ctrl+C the netcat process):


$ nc -p 5555 -kl

-- output --
sleeping 1s
Connected!
Hello world

-- java --

import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SocketChannel;
import java.util.Arrays;
import java.util.concurrent.Callable;
import java.util.concurrent.Executors;

public class Test {

 public static String block() {
 // nc -p 5555 -kl
 try {
 System.out.println("sleeping 1s");
 Thread.sleep(1000);
 var socket = SocketChannel.open();
 socket.connect(new InetSocketAddress("localhost", 5555));
 System.out.println("Connected!");
 socket.read(ByteBuffer.allocate(10)); // I was hoping this would allow the
other task to be scheduled
 return "End";
 } catch (Exception e) {
 e.printStackTrace();
 return "Failed";
 }
 }

 public static String print() {
 System.out.println("Hello world");
 return "Printed";
 }

 public static void main(String[] args) throws Throwable {
 var e = Executors.newFixedThreadPool(1,
Thread.builder().virtual().factory());
 Callable<String> t1 = Test::block;
 Callable<String> t2 = Test::print;

 var tasks = Arrays.asList(t1, t2);
 var fut = e.invokeAll(tasks);
 }
}

--
Thanks