INNER CODE UNIT · Java

DataLoader_Batching_Caching_JCStress

graphql-java/java-dataloader · src/jcstress/java/org/dataloader/DataLoader_Batching_Caching_JCStress.java:19

public class DataLoader_Batching_Caching_JCStress {


    AtomicInteger counter = new AtomicInteger();
    AtomicInteger batchLoaderCount = new AtomicInteger();
    volatile boolean finished1;
    volatile boolean finished2;


    BatchLoader<String, String> batchLoader = keys -> {
        return CompletableFuture.supplyAsync(() -> {
            batchLoaderCount.getAndAdd(keys.size());
            return keys;
        });
    };
    DataLoader<String, String> dataLoader = DataLoaderFactory.newDataLoader(batchLoader);

    public DataLoader_Batching_Caching_JCStress() {

View source record →