Google大佬都用的广播goAsync源码分析

下面就详细讲解一下“Google大佬都用的广播goAsync源码分析”的完整攻略。

什么是广播goAsync

广播goAsync是Android中一种异步广播处理方式，它可以在主线程之外执行广播接收器的代码，避免了主线程阻塞。在Android系统中，广播是一种重要的机制，它可以在应用程序间传递消息。但是，当广播接收器执行耗时操作时，就会阻塞UI线程，影响用户体验，这时就需要使用广播goAsync来异步处理广播。

广播goAsync的使用方法

使用广播goAsync处理广播的步骤如下：

创建广播接收器

首先需要创建一个广播接收器，在其中实现异步处理逻辑。示例代码如下：

public class MyReceiver extends BroadcastReceiver {
    @Override
    public void onReceive(Context context, Intent intent) {
        // 获取异步广播结果回调对象
        final PendingResult pendingResult = goAsync();
        // 在异步线程中处理广播
        new Thread(new Runnable() {
            @Override
            public void run() {
                //处理广播
                //...
                //异步处理完成后调用finish方法，通知系统已经处理完广播
                pendingResult.finish();
            }
        }).start();
    }
}

注册广播接收器

注册广播接收器的方法有两种，一种是在代码中动态注册，另一种是在AndroidManifest.xml文件中静态注册。

动态注册

动态注册广播接收器的示例代码如下：

//创建广播接收器实例
MyReceiver myReceiver = new MyReceiver();
//创建IntentFilter对象
IntentFilter filter = new IntentFilter();
//添加要监听的广播类型
filter.addAction("com.example.broadcast.MY_BROADCAST");
//注册广播接收器
registerReceiver(myReceiver, filter);

静态注册

在AndroidManifest.xml文件中静态注册广播接收器的示例代码如下：

<receiver android:name=".MyReceiver">
    <intent-filter>
        <action android:name="com.example.broadcast.MY_BROADCAST" />
    </intent-filter>
</receiver>

发送广播

发送广播的方法有两种，一种是发送标准广播，另一种是发送有序广播。

发送标准广播

发送标准广播的示例代码如下：

//创建Intent对象
Intent intent = new Intent();
//设置广播类型
intent.setAction("com.example.broadcast.MY_BROADCAST");
//发送标准广播
sendBroadcast(intent);

发送有序广播

发送有序广播的示例代码如下：

//创建Intent对象
Intent intent = new Intent();
//设置广播类型
intent.setAction("com.example.broadcast.MY_BROADCAST");
//发送有序广播
sendOrderedBroadcast(intent, null);

广播goAsync源码分析

为了更好地了解广播goAsync的实现原理，下面对其源码进行分析。

BroadcastReceiver.goAsync

广播接收器的goAsync方法是广播goAsync实现的核心。源码如下：

public final PendingResult goAsync() {
    if (mPendingResult == null) {
        // 创建PendingResult实例
        mPendingResult = new PendingResult(this, mOrderedHint, mInitialSticky, mDebugUnregister);
    }
    return mPendingResult;
}

BroadcastReceiver.PendingResult

PendingResult是广播goAsync的回调接口，它可以在异步线程中执行广播接收器里的代码。PendingResult的实现源码如下：

public static final class PendingResult {
    // 接收器对象
    private final BroadcastReceiver mReceiver;
    // 广播类型(有序广播或标准广播)
    private final String mType;
    // 是否为有序广播
    private final boolean mOrdered;
    // 是否是初次注册
    private final boolean mInitialSticky;
    // 是否为调试模式
    private final boolean mDebug;
    // resultCode，用于广播结果回传
    private int mResultCode;
    // resultData，用于广播结果回传
    private String mResultData;
    // resultExtras，用于广播结果回传
    private Bundle mResultExtras;
    // 意图
    private final Intent mResultAbort;

    public void setResultCode(int code) {
        mResultCode = code;
    }

    public void setResultData(String data) {
        mResultData = data;
    }

    public void setResultExtras(Bundle extras) {
        mResultExtras = extras;
    }

    public void setResult(int code, String data, Bundle extras) {
        mResultCode = code;
        mResultData = data;
        mResultExtras = extras;
    }

    public void abortBroadcast() {
        if (mOrdered) {
            mResultAbort.setFlags(Intent.FLAG_RECEIVER_ABORTED);
        } else {
            throw new RuntimeException("Abort not supported for asynchronous broadcasts");
        }
    }

    public void finish() {
        if (mDebug) {
            Log.i(TAG, "Finished result " + mResultCode + ", data '" + mResultData + "', extras " + mResultExtras);
        }
        final IActivityManager am = ActivityManagerNative.getDefault();
        if (mOrdered) {
            try {
                am.finishReceiver(mReceiver, mResultCode, mResultData, mResultExtras, mResultAbort, mInitialSticky);
            } catch (RemoteException e) {
                // ...
            }
        } else {
            try {
                am.finishReceiver(mReceiver, mResultData, mResultExtras, mInitialSticky);
            } catch (RemoteException e) {
                // ...
            }
        }
    }
}

总结

以上就是“Google大佬都用的广播goAsync源码分析”的完整攻略。广播goAsync是一种在Android系统中用于异步处理广播的机制。使用广播goAsync需要创建一个广播接收器，并在其中实现异步处理逻辑。同时，我们也可以通过阅读源码，更好地了解广播goAsync的实现原理。