INNER CODE UNIT · Java

createNewThreadIfPossible

RuedigerMoeller/kontraktor · attic/ElasticScheduler.java:351

    private DispatcherThread createNewThreadIfPossible() {
        for (int i = 0; i < threads.length; i++) {
            DispatcherThread thread = threads[i];
            if (thread == null) {
                DispatcherThread th = createDispatcherThread();
                threads[i] = th;
                return th;
            }
        }
        return null;
    }

    /**
     * @return an UNSTARTED dispatcher thread
     */
    protected DispatcherThread createDispatcherThread() {
        return new DispatcherThread(this);
    }

View source record →