package com.bytedance.sdk.openadsdk.maa;

import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

/* JADX INFO: loaded from: classes2.dex */
public class ro {
    private fm jnr;
    private wu ro;
    private int yz;
    private ScheduledExecutorService fm = null;

    /* JADX INFO: renamed from: lb, reason: collision with root package name */
    private long f7484lb = 0;

    public interface fm {
    }

    public ro(wu wuVar, int i10) {
        this.ro = wuVar;
        this.yz = i10;
    }

    public void fm(long j10) {
        this.f7484lb = j10;
    }

    public boolean ro() {
        ScheduledExecutorService scheduledExecutorService = this.fm;
        if (scheduledExecutorService != null) {
            return scheduledExecutorService.isShutdown();
        }
        return true;
    }

    public void fm(int i10) {
        ScheduledExecutorService scheduledExecutorServiceNewScheduledThreadPool = Executors.newScheduledThreadPool(1);
        this.fm = scheduledExecutorServiceNewScheduledThreadPool;
        scheduledExecutorServiceNewScheduledThreadPool.scheduleAtFixedRate(new Runnable() { // from class: com.bytedance.sdk.openadsdk.maa.ro.1
            @Override // java.lang.Runnable
            public void run() {
                System.currentTimeMillis();
                long unused = ro.this.f7484lb;
                if (System.currentTimeMillis() - ro.this.f7484lb > ro.this.yz) {
                    ro.this.fm.shutdown();
                    if (ro.this.ro != null) {
                        ro.this.ro.ro(0, "Automatic detection of stuck");
                    }
                    if (ro.this.jnr != null) {
                        fm unused2 = ro.this.jnr;
                    }
                }
            }
        }, 0L, i10, TimeUnit.MILLISECONDS);
    }

    public void fm() {
        ScheduledExecutorService scheduledExecutorService = this.fm;
        if (scheduledExecutorService != null) {
            scheduledExecutorService.shutdown();
        }
    }
}