package io.netty.util.internal.shaded.org.jctools.queues;

/* JADX INFO: loaded from: classes.dex */
public interface MessagePassingQueue<T> {
    public static final int UNBOUNDED_CAPACITY = -1;

    public interface Consumer<T> {
        void accept(T t);
    }

    public interface ExitCondition {
        boolean keepRunning();
    }

    public interface Supplier<T> {
        T get();
    }

    public interface WaitStrategy {
        int idle(int i2);
    }

    int capacity();

    void clear();

    int drain(Consumer<T> consumer);

    int drain(Consumer<T> consumer, int i2);

    void drain(Consumer<T> consumer, WaitStrategy waitStrategy, ExitCondition exitCondition);

    int fill(Supplier<T> supplier);

    int fill(Supplier<T> supplier, int i2);

    void fill(Supplier<T> supplier, WaitStrategy waitStrategy, ExitCondition exitCondition);

    boolean isEmpty();

    boolean offer(T t);

    T peek();

    T poll();

    boolean relaxedOffer(T t);

    T relaxedPeek();

    T relaxedPoll();

    int size();
}