[zeromq-dev] Interrupt and cleanly exit java application

[Mohit Anchlia]

I am using the following code to connect to a socket, however when I exit
the application not all the threads exit. Lot of the threads are waiting,
Is there a better way to cleanly exit the application?

"Thread-6" prio=10 tid=0x00007f0f043d8800 nid=0xff9 runnable
[0x00007f0ef04ab000]
   java.lang.Thread.State: RUNNABLE
        at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
        at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)
        at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:79)
        at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:87)
        - locked <0x0000000093b1f0a8> (a sun.nio.ch.Util$2)
        - locked <0x0000000093b1f098> (a
java.util.Collections$UnmodifiableSet)
        - locked <0x0000000093b1efb8> (a sun.nio.ch.EPollSelectorImpl)
        at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:98)
        at zmq.Signaler.wait_event(Signaler.java:135)
        at zmq.Mailbox.recv(Mailbox.java:105)

ZMQ.Socket socket = sockets.get();

*if* (*null* == socket) {

socket = context.socket(ZMQ.*REP*);

sockets.set(socket);

}

socket.connect(jmsUrl);

 *while* (*true*) {

 // Wait for next request from client (C string)

 *try* {

String request = socket.recvStr(0);

*log*.info(Thread.*currentThread*().getName());

 // Do some 'work'

String response = *null*;

response = doWork(request);

 // Send reply back to client (C string)

socket.send(response, 0);

 } *catch* (ZMQException e) {

*if* (e.getErrorCode() == ZMQ.Error.*ETERM*.getCode()) {

*log*.warn("Exiting", e);

*break*;

}*else*{

*log*.error("Unable to send request", e);

}

}

}

*public* *void* cleanUp() {

*log*.info("Close Called");

 ZMQ.Socket socket = sockets.get();

*if* (*null* != socket) {

socket.close();

}

*this*.context.term();

 }
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <https://lists.zeromq.org/pipermail/zeromq-dev/attachments/20140912/dde84cba/attachment.htm>