我创建AsynchronousServerSocketChannel,一切都很好,直到我想要关闭服务器套接字。我用特殊的消息在客户端上创建AsynchronousSocketChannel,该消息调用函数关闭服务器和所有套接字通道,服务器是关闭的,但最终没有执行阻塞,为什么?
检查代码:
public void openServerSocket(int sport) {
port = sport;
policyFile = createPolicy(new String[]{"*:"+port});
try {
//group = AsynchronousChannelGroup.withThreadPool(Executors.newSingleThreadExecutor());
//group.awaitTermination(1, TimeUnit.SECONDS);
server = AsynchronousServerSocketChannel.open();
server.bind(new InetSocketAddress(sport));
server.accept(null, this);
while(isOpen) {
//System.out.println("running server socket");
}
}catch(Exception ex) {
this.message = ex.getMessage();
System.out.println("Server: " + ex.getMessage());
}finally {
System.out.println("Finall serversocket closing!");
for(SocketHandler sh : sockets) {
sh.close();
}
if(server != null) {
try {
server.close();
server = null;
}catch(Exception ex2) {
this.message = ex2.getMessage();
}
}
sockets.clear();
sockets = null;
//this.message = "server socket closed";
System.out.println("server socket down");
}
}
@Override
public void completed(AsynchronousSocketChannel socket, Void attachment) {
System.out.println("new connection");
SocketHandler sh = new SocketHandler(socket, this);
server.accept(null, this);
}
@Override
public void failed(Throwable exc, Void attachment) {
System.out.println("Server Failed accept:" + exc.getMessage());
}
public void closeServerSocket() {
System.out.println("Closing server socket! " + server);
this.isOpen = false;
}因此函数closeServerSocket被调用,并且我将false设置为变量isOpen,它一直循环,但是当我将false设置为isOpen var时,当仍然在循环时,最终不会执行?
发布于 2014-04-25 19:56:25
这看起来像是几个线程之间的通信问题。从代码中,我猜您的while(isOpen)循环运行在与类的closeServerSocket()方法不同的线程中。要验证这一点,请将Thread.currentThread()添加到打印语句中。
如果是这样的话,您可以通过声明isOpen为volatile来纠正这种情况。如果没有volatile,则不能保证任何其他线程都会看到所写的值。使用volatile,可以保证(我对发生-之前的解释),一个访问变量的线程(根据挂钟时间)将看到更改的值。
与volatile不同,您可能更喜欢AtomicBoolean。
https://stackoverflow.com/questions/23291426
复制相似问题