Android:在当前线程执行完成之前强制主运行循环运行



在iOS上,如果我想让当前执行线程等待(例如:块)和主循环运行,以便主队列中的下一个执行线程可以执行,我调用:

[[NSRunLoop currentRunLoop] runMode:NSDefaultRunLoopMode beforeDate:[NSDate date]];

我该如何在Android上做同样的事情呢?

这确实可以在Android中实现。沙查尔的答案是正确的。问题不在于主循环会阻塞(除非代码在主线程上执行,但这不是问题所建议的)。问题是另一个线程不会阻塞,而只是在while循环中循环并消耗CPU周期。下面是我在我的应用程序中使用的一个阻塞运行的main方法:

/**
 * Runs the runnable on the main UI thread. If called from a thread other than the UI thread,
 * this method will block the calling thread and return only after the runnable has completed
 * execution on the main UI thread.
 * @param runnable Runnable to run on the main UI thread
 */
public static void blockingRunOnMain(Runnable runnable) {
    if (Looper.myLooper() == Looper.getMainLooper()) { // Already on UI thread run immediately
        runnable.run();
    }
    else { // Queue to run on UI thread
        final MainRunMonitor lock = new MainRunMonitor();
        Handler mainHandler = new Handler(Looper.getMainLooper());
        mainHandler.post(runnable);
        // Task to notify calling thread when runnable complete
        mainHandler.post(new Runnable() {
            @Override
            public void run() {
                synchronized (lock) {
                    lock.mRunComplete = true;
                    lock.notify();
                }
            }
        });
        // Block calling thread until runnable completed on UI thread
        boolean interrupted = false;
        try {
            synchronized (lock) {
                while (!lock.mRunComplete) {
                    try {
                        lock.wait();
                    } catch (InterruptedException e) {
                        // Received interrupt signal, but still haven't been notified, continue waiting
                        interrupted = true;
                    }
                }
            }
        } finally {
            if (interrupted) {
                Thread.currentThread().interrupt(); // Restore interrupt to be used higher on call stack (we're not using it to interrupt this task)
            }
        }
    }
}

MainRunMonitor是一个简单的类,在我的例子中是实现blockingRunOnMain()的类的私有内部类:

/**
 * Monitor to lock calling thread while code is executed on UI thread.
 */
private static class MainRunMonitor {
    private boolean mRunComplete = false;
}

blockingRunOnMain()通过传递Runnable在主线程上运行来使用:

blockingRunOnMain(new Runnable() {
    @Override
    public void run() {
        workToDoSynchronouslyOnMain();
    }
});

blockingRunOnMain()方法的第一部分检查该方法是否从主线程调用,如果是,则立即执行代码。由于blockingRunOnMain()的功能是在方法返回之前同步运行Runnable代码,因此即使从主线程本身调用,也会得到相同的结果。

如果该方法是从主线程以外的线程调用的,那么我们将Runnable发送给与主线程的Looper绑定的Handler。在发布Runnable参数之后,我们随后发布另一个Runnable,它将在Runnable参数完成执行后执行,因为Handler按顺序执行发布的Message s和Runnable s。第二个Runnable用来通知被阻塞的线程,工作已经在主线程上完成了。

在发布第二个Runnable之后,我们现在阻塞后台线程并等待直到我们收到通知。同步在lock上执行的操作是很重要的,这样操作在每个线程上都是原子的。

后台线程调用监视器上的wait()并等待mRunComplete == true。如果它得到一个InterruptedException,在我们完成后继续等待并恢复线程的中断状态是很重要的,因为我们自己不使用中断机制来取消我们的任务,恢复它允许调用堆栈上更高的另一个方法来处理中断。参见"处理InterruptedException"。

Runnable参数完成执行并且第二个发布的Runnable执行时,它简单地将mRunComplete设置为true并通知被阻塞的线程继续执行,它发现mRunComplete == true现在从blockingRunOnMain()返回,在主UI线程上同步执行Runnable参数。

一个简短的解决方法是使用一个布尔值,该值在下一个主线程循环中被更改。

在主线程上运行可以通过runOnUIthread完成(或者自己获取主线程循环器)移动到下一个循环可以很容易地完成handler.postDelayed(Runnable run, long delayMills),并且没有时间延迟。

所以你可以这样做:

nextMainLoopDone = false;//This should be changed to a thread safe boolean, could use AtomicBoolean
new Handler(Looper.getMainLooper()).postDelayed(new Runnable() {
    @Override
    public void run() {
        nextMainLoopDone = true;
    }
}, 1/* delay for no time, just to next loop*/);
while(!nextMainLoopDone) {
    ;
}

我很抱歉让你失望了,但是你所要求的在Android上是不可能做到的。

相关内容

  • 没有找到相关文章

最新更新