src/main/java/com/it_jaros/jscanner/scan/engine/ProducerState.java


1
2
3
4
5
6
7
8
9
10
11
12
13

package com.it_jaros.jscanner.scan.engine;

import java.util.concurrent.CompletionService;
import java.util.concurrent.Semaphore;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicInteger;

public record ProducerState<OUTPUT>(
        AtomicBoolean running,
        AtomicInteger inPipeline,
        Semaphore activeWorkers,
        CompletionService<OUTPUT> completionService
) {}