Hello there,
I experience some strange blocking problems using the write method of
the INonBlockingConnection class. It wait for long time. Here is a jstack:
"XSocket Worker Thread" prio=10 tid=0x00007f6d64087800 nid=0x5e76 in
Object.wait() [0x00007f6d6a70d000]
java.lang.Thread.State: WAITING (on object monitor)
at java.lang.Object.wait(Native Method)
- waiting on <0x00000000e0cbc9d8> (a
org.xsocket.connection.NonBlockingConnection$SynchronWriter)
at
org.xsocket.connection.NonBlockingConnection$SynchronWriter.syncWrite(NonBlockingConnection.java:2374)
- locked <0x00000000e0cbc9d8> (a
org.xsocket.connection.NonBlockingConnection$SynchronWriter)
at
org.xsocket.connection.NonBlockingConnection.internalFlush(NonBlockingConnection.java:2211)
at
org.xsocket.connection.NonBlockingConnection.onWriteDataInserted(NonBlockingConnection.java:2045)
at
org.xsocket.connection.AbstractNonBlockingStream.write(AbstractNonBlockingStream.java:1060)
at
org.xsocket.connection.AbstractNonBlockingStream.write(AbstractNonBlockingStream.java:1039)
at
org.xsocket.connection.SynchronizedNonBlockingConnection.write(SynchronizedNonBlockingConnection.java:552)
- locked <0x00000000e0cbc748> (a
org.xsocket.connection.NonBlockingConnection)
at
com.egt.egm.server.roulette.xsocket_server.XSocketDataHandler.broadcastMessage(XSocketDataHandler.java:521)
at
com.egt.egm.server.roulette.xsocket_server.XSocketMessageWorker.run(XSocketMessageWorker.java:54)
at java.lang.Thread.run(Thread.java:662)
Can you help in anyway? Also I store all active connections in a map
which is accessed concurrently and I am using the suggested final
INonBlockingConnection nbc = ConnectionUtils
.synchronizedConnection(_nbc).
Thanks in advance.
|
