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


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

package com.it_jaros.jscanner;

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
) {}