Question

我花了很强的时间,把这.起来。我有以下法典:

    if (selector.select(1000) <= 0) {
        return;
    }
    Set<SelectionKey> selectionKeys = selector.selectedKeys();
    for (SelectionKey key : selectionKeys) {
        try { 
            SocketEventHandler handler = (SocketEventHandler) key.attachment();
            if (key.isValid() && key.isAcceptable()) {
                handler.becomesAcceptable(key);
            }
            if (key.isValid() && key.isReadable()) {
                handler.becomesReadable(key);
            }

            if (key.isValid() && key.isWritable()) {
                handler.becomesWritable(key);
            }

            if (key.isValid() && key.isConnectable()) {
                handler.becomesConnectable(key);
            }
        } catch (IOException e) {
            key.cancel();
        }
    }
    selector.selectedKeys().clear();

The following Handler Code for案文如下:

synchronized public void becomesReadable(SelectionKey key) throws IOException {
    ByteBuffer temporaryBuffer = ByteBuffer.allocate(DEFAULT_BYTE_BUFFER_SIZE);
    temporaryBuffer.position(0);
    int read = -1;
    try {
        read = channel.read(temporaryBuffer);
    } catch (IOException e) {
        prefixLogger.debug("Trace:", e);
        close();
    }
    ...
}

And that s the only point where the handler function is ever called. So if I ever get into the becomeReadable() function the channel is in readable state, yet the call to read() blocks without ever returning. Is there something I missed?

Answer 1

我不禁要问,为什么这一方法能够同步使用。使用NIO较好时的同步程度较低。

我也想知道,为什么你不把国际海洋研究组织排除在外,为什么你只是取消钥匙,而不是关闭渠道。因此,我也想知道,我/奥先生的例外情况是什么,你知道你没有。

分配缓冲费用也非常昂贵:每读一次,你们就应该有一席之地,在分配给该频道的SocketEventHandler案。

Answer 2

您在《刑法》中是否打上了<条码>。

很难告诉你在这里使用哪一种渠道,但我想.SocketChannel是按最初的阻挡模式建立的。

友情链接