package 㳳.ῲ.K;

import java.util.logging.Level;

/* renamed from: 㳳.ῲ.K.ῲ  reason: contains not printable characters */
/* compiled from: BackgroundPoster */
public final class RunnableC2409 implements Runnable, AbstractC2407 {

    /* renamed from: ʬ  reason: contains not printable characters */
    public final C2399 f8331;

    /* renamed from: ῲ  reason: contains not printable characters */
    public final C2416 f8332 = new C2416();

    /* renamed from: 㸾  reason: contains not printable characters */
    public volatile boolean f8333;

    public RunnableC2409(C2399 r1) {
        this.f8331 = r1;
    }

    public void run() {
        while (true) {
            try {
                C2408 r1 = this.f8332.m6471(1000);
                if (r1 == null) {
                    synchronized (this) {
                        r1 = this.f8332.m6470();
                        if (r1 == null) {
                            this.f8333 = false;
                            return;
                        }
                    }
                }
                this.f8331.m6447(r1);
            } catch (InterruptedException e) {
                AbstractC2417 r2 = this.f8331.f8302;
                Level level = Level.WARNING;
                r2.m6474(level, Thread.currentThread().getName() + " was interruppted", e);
                return;
            } finally {
                this.f8333 = false;
            }
        }
    }

    @Override // 㳳.ῲ.K.AbstractC2407
    /* renamed from: K  reason: contains not printable characters */
    public void m6459(C2403 r1, Object obj) {
        C2408 r12 = C2408.m6457(r1, obj);
        synchronized (this) {
            this.f8332.m6472(r12);
            if (!this.f8333) {
                this.f8333 = true;
                this.f8331.f8303.execute(this);
            }
        }
    }
}
