lultimouomo
commented
6 years ago Please not that I get the same result if instead of terminating the program with SIGTERM I replace the shutdown hook with this code to cause the main loop to exit by pressing enter in the console:
new Thread(() -> {
try {
System.in.read();
shutDown = true;
} catch (Exception e) {
}
}).start();
Runtime.getRuntime().addShutdownHook(new Thread(() -> {
try {
shutDownLatch.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
}));
fredoboulo
The following program expects a hartbeat from a PUB socket once a second (actually waits 2 seconds for margin); if it doesn't receive it, it disconnects and reconnects the SUB socket. If I disconnect and reconnect the WiFi on the computer running it (with PUB on a separate computer) I can get the closing of the ZMQ.Context to hang forever. The logs also shows that somehow the socket connection and subscribing thinkgs it succeeds even though the network is disconnected (obviously the heartbeat is not received).
This is the log for a run, lines starting with "###" are comments about when I connected or disconnected the wifi or stopped the program.