INNER CODE UNIT · Java

maxActors2Remove

RuedigerMoeller/kontraktor · attic/ElasticScheduler.java:485

            int maxActors2Remove = Math.min(qList.length, qList.length / 5 + 1); // do several steps to get better spread
            for (int i = 0; i < maxActors2Remove; i++)
            {
                Actor actor = qList[i];
                // sanity, remove me later
                if ( actor.getActorRef() != actor )
                    throw new RuntimeException("this should not happen ever");
                dispatcherThread.removeActorImmediate(actor);
                minLoadThread.addActor(actor);
                if (REALLY_DEBUG_SCHEDULING)
                    Log.Info(this,"move for idle " + actor.getQSizes() + " myload " + dispatcherThread.getAccumulatedQSizes() + " actors " + qList.length);
            }
        }
    }

    @Override
    public BackOffStrategy getBackoffStrategy() {
        return backOffStrategy;

View source record →