package g.i.a.b.d;

import java.util.concurrent.LinkedBlockingDeque;

/* JADX INFO: loaded from: classes.dex */
public abstract class a<T> extends Thread {

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public volatile boolean f5325f = false;

    /* JADX INFO: renamed from: m, reason: collision with root package name */
    public LinkedBlockingDeque<T> f5326m = new LinkedBlockingDeque<>();

    public void a(T t2) {
        synchronized (this.f5326m) {
            this.f5326m.add(t2);
        }
    }

    public void b() {
        synchronized (this.f5326m) {
            this.f5326m.clear();
        }
    }

    public T c() {
        try {
            return this.f5326m.take();
        } catch (InterruptedException e2) {
            e2.printStackTrace();
            return null;
        }
    }
}