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