void com.griddynamics.jagger.invoker.ExclusiveAccessLoadBalancer< Q, E >.init

(

)

Definition at line 76 of file ExclusiveAccessLoadBalancer.java.

                       {
        synchronized (lock) {
            if (initialized) {
                log.debug("already initialized. returning...");
                return;
            }
            
            super.init();
    
            PairSupplier<Q, E> pairSupplier = getPairSupplier();
            List<Pair<Q, E>> pairList = new ArrayList<>(pairSupplier.size());

            int index = 0;
            int step = 1;
            if (kernelInfo != null) { // then from all the provided pairs pick only those under this node's index.
                index = kernelInfo.getKernelId();
                step = kernelInfo.getKernelsNumber();
            }
            for (; index < pairSupplier.size(); index += step) {
                pairList.add(pairSupplier.get(index));
            }
            
            if (Objects.nonNull(randomnessSeed)) {
                log.info("'randomnessSeed' value is not null. Going to shuffle the pairs");
                Collections.shuffle(pairList, new Random(randomnessSeed));
            }
            
            log.info("{} pairs on this node to balance", pairList.size());
            log.debug("Pairs to load balance: {}", pairList);
            
            pairQueue = new ArrayBlockingQueue<>(pairSupplier.size(), true, pairList);
        }
    }