package com.bytedance.sdk.component.wu.fm;

import com.bytedance.sdk.component.wu.fm.lb;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

/* JADX INFO: loaded from: classes.dex */
public class yz<T extends lb> {
    private int fm;
    private BlockingQueue<T> ro = new LinkedBlockingQueue();

    private yz(int i10) {
        this.fm = i10;
    }

    public static yz fm(int i10) {
        return new yz(i10);
    }

    public T fm() {
        return this.ro.poll();
    }

    public boolean fm(T t10) {
        if (t10 == null) {
            return false;
        }
        t10.fm();
        if (this.ro.size() >= this.fm) {
            return false;
        }
        return this.ro.offer(t10);
    }
}