INNER CODE UNIT · Java

threadStopped

RuedigerMoeller/kontraktor · attic/ElasticScheduler.java:227

    public void threadStopped(DispatcherThread th) {
        synchronized(threads) {
            for (int i = 0; i < threads.length; i++) {
                if (threads[i] == th) {
                    threads[i] = null;
                    return;
                }
            }
        }
        if ( th.isIsolated() ) {
            if (DEBUG_SCHEDULING)
                Log.Info(this, "  was decoupled one.");
            isolateCount.decrementAndGet();
        }
//        throw new RuntimeException("Oops. Unknown Thread");
    }

    class CallbackInvokeHandler implements InvocationHandler {

View source record →