import com.sun.corba.se.pept.transport.ListenerThread; //导入依赖的package包/类
private void destroyListenerThread(EventHandler eventHandler)
{
    if (orb.transportDebugFlag) {
        dprint(".destroyListenerThread: " + eventHandler);
    }
    ListenerThread listenerThread = (ListenerThread)
        listenerThreads.get(eventHandler);
    if (listenerThread == null) {
        if (orb.transportDebugFlag) {
            dprint(".destroyListenerThread: cannot find ListenerThread - ignoring.");
        }
        return;
    }
    listenerThreads.remove(eventHandler);
    listenerThread.close();
}
 

import com.sun.corba.se.pept.transport.ListenerThread; //导入依赖的package包/类
public void close()
{
    if (orb.transportDebugFlag) {
        dprint(".close");
    }

    if (isClosed()) {
        if (orb.transportDebugFlag) {
            dprint(".close: already closed");
        }
        return;
    }

    setClosed(true);

    Iterator i;

    // Kill listeners.

    i = listenerThreads.values().iterator();
    while (i.hasNext()) {
        ListenerThread listenerThread = (ListenerThread) i.next();
        listenerThread.close();
    }

    // Kill readers.

    i = readerThreads.values().iterator();
    while (i.hasNext()) {
        ReaderThread readerThread = (ReaderThread) i.next();
        readerThread.close();
    }

    // Selector

    try {
        if (selector != null) {
            // wakeup Selector thread to process close request
            selector.wakeup();
        }
    } catch (Throwable t) {
        if (orb.transportDebugFlag) {
            dprint(".close: selector.close: " + t);
        }
    }
}
 

import com.sun.corba.se.pept.transport.ListenerThread; //导入依赖的package包/类
public void close()
{
    if (orb.transportDebugFlag) {
        dprint(".close");
    }

    if (isClosed()) {
        if (orb.transportDebugFlag) {
            dprint(".close: already closed");
        }
        return;
    }

    setClosed(true);

    Iterator i;

    // Kill listeners.

    i = listenerThreads.values().iterator();
    while (i.hasNext()) {
        ListenerThread listenerThread = (ListenerThread) i.next();
        listenerThread.close();
    }

    // Kill readers.

    i = readerThreads.values().iterator();
    while (i.hasNext()) {
        ReaderThread readerThread = (ReaderThread) i.next();
        readerThread.close();
    }

   clearDeferredRegistrations();

    // Selector

    try {
        if (selector != null) {
            // wakeup Selector thread to process close request
            selector.wakeup();
        }
    } catch (Throwable t) {
        if (orb.transportDebugFlag) {
            dprint(".close: selector.wakeup: ", t);
        }
    }
}