首页
学习
活动
专区
圈层
工具
发布
社区首页 >问答首页 >AsynchronousServerSocketChannel最终没有执行

AsynchronousServerSocketChannel最终没有执行
EN

Stack Overflow用户
提问于 2014-04-25 11:12:47
回答 1查看 214关注 0票数 1

我创建AsynchronousServerSocketChannel,一切都很好,直到我想要关闭服务器套接字。我用特殊的消息在客户端上创建AsynchronousSocketChannel,该消息调用函数关闭服务器和所有套接字通道,服务器是关闭的,但最终没有执行阻塞,为什么?

检查代码:

代码语言:javascript
复制
 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时,当仍然在循环时,最终不会执行?

EN

回答 1

Stack Overflow用户

回答已采纳

发布于 2014-04-25 19:56:25

这看起来像是几个线程之间的通信问题。从代码中,我猜您的while(isOpen)循环运行在与类的closeServerSocket()方法不同的线程中。要验证这一点,请将Thread.currentThread()添加到打印语句中。

如果是这样的话,您可以通过声明isOpenvolatile来纠正这种情况。如果没有volatile,则不能保证任何其他线程都会看到所写的值。使用volatile,可以保证(我对发生-之前的解释),一个访问变量的线程(根据挂钟时间)将看到更改的值。

volatile不同,您可能更喜欢AtomicBoolean

票数 1
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/23291426

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档