系统是如何控制进程四大组件的?ActivityThread的主线程管理

主线程管理类

ActivityThread:它管理应用程序进程中主线程的执行,按照活动管理器的请求调度和执行Activity、broadcasts和其他操作。该类里面也有控制进程回收机制的逻辑。其内部通过继承handler的H类来实现主线程控制和调度。

public final class ActivityThread {
         ...
        final H mH = new H();
        private class H extends Handler {
        public static final int LAUNCH_ACTIVITY         = 100;
        public static final int PAUSE_ACTIVITY          = 101;
        public static final int PAUSE_ACTIVITY_FINISHING= 102;
        public static final int STOP_ACTIVITY_SHOW      = 103;
        public static final int STOP_ACTIVITY_HIDE      = 104;
        public static final int SHOW_WINDOW             = 105;
        public static final int HIDE_WINDOW             = 106;
        public static final int RESUME_ACTIVITY         = 107;
        public static final int SEND_RESULT             = 108;
        public static final int DESTROY_ACTIVITY        = 109;
        public static final int BIND_APPLICATION        = 110;
        public static final int EXIT_APPLICATION        = 111;
        public static final int NEW_INTENT              = 112;
        public static final int RECEIVER                = 113;
        public static final int CREATE_SERVICE          = 114;
        public static final int SERVICE_ARGS            = 115;
        public static final int STOP_SERVICE            = 116;

        public static final int CONFIGURATION_CHANGED   = 118;
        public static final int CLEAN_UP_CONTEXT        = 119;
        public static final int GC_WHEN_IDLE            = 120;
        public static final int BIND_SERVICE            = 121;
        public static final int UNBIND_SERVICE          = 122;
        public static final int DUMP_SERVICE            = 123;
        public static final int LOW_MEMORY              = 124;
        public static final int ACTIVITY_CONFIGURATION_CHANGED = 125;
        public static final int RELAUNCH_ACTIVITY       = 126;
        public static final int PROFILER_CONTROL        = 127;
        public static final int CREATE_BACKUP_AGENT     = 128;
        public static final int DESTROY_BACKUP_AGENT    = 129;
        public static final int SUICIDE                 = 130;
        public static final int REMOVE_PROVIDER         = 131;
        public static final int ENABLE_JIT              = 132;
        public static final int DISPATCH_PACKAGE_BROADCAST = 133;
        public static final int SCHEDULE_CRASH          = 134;
        public static final int DUMP_HEAP               = 135;
        public static final int DUMP_ACTIVITY           = 136;
        public static final int SLEEPING                = 137;
        public static final int SET_CORE_SETTINGS       = 138;
        public static final int UPDATE_PACKAGE_COMPATIBILITY_INFO = 139;
        public static final int TRIM_MEMORY             = 140;
        public static final int DUMP_PROVIDER           = 141;
        public static final int UNSTABLE_PROVIDER_DIED  = 142;
        public static final int REQUEST_ASSIST_CONTEXT_EXTRAS = 143;
        public static final int TRANSLUCENT_CONVERSION_COMPLETE = 144;
        public static final int INSTALL_PROVIDER        = 145;
        public static final int ON_NEW_ACTIVITY_OPTIONS = 146;
        public static final int CANCEL_VISIBLE_BEHIND = 147;
        public static final int BACKGROUND_VISIBLE_BEHIND_CHANGED = 148;
        public static final int ENTER_ANIMATION_COMPLETE = 149;
        public static final int START_BINDER_TRACKING = 150;
        public static final int STOP_BINDER_TRACKING_AND_DUMP = 151;
        public static final int MULTI_WINDOW_MODE_CHANGED = 152;
        public static final int PICTURE_IN_PICTURE_MODE_CHANGED = 153;
        public static final int LOCAL_VOICE_INTERACTION_STARTED = 154;
        public static final int ATTACH_AGENT = 155;
        public static final int APPLICATION_INFO_CHANGED = 156;
        public static final int ACTIVITY_MOVED_TO_DISPLAY = 157;

        String codeToString(int code) {
            if (DEBUG_MESSAGES) {
                switch (code) {
                    case LAUNCH_ACTIVITY: return "LAUNCH_ACTIVITY";
                    case PAUSE_ACTIVITY: return "PAUSE_ACTIVITY";
                    case PAUSE_ACTIVITY_FINISHING: return "PAUSE_ACTIVITY_FINISHING";
                    case STOP_ACTIVITY_SHOW: return "STOP_ACTIVITY_SHOW";
                    case STOP_ACTIVITY_HIDE: return "STOP_ACTIVITY_HIDE";
                    case SHOW_WINDOW: return "SHOW_WINDOW";
                    case HIDE_WINDOW: return "HIDE_WINDOW";
                    case RESUME_ACTIVITY: return "RESUME_ACTIVITY";
                    case SEND_RESULT: return "SEND_RESULT";
                    case DESTROY_ACTIVITY: return "DESTROY_ACTIVITY";
                    case BIND_APPLICATION: return "BIND_APPLICATION";
                    case EXIT_APPLICATION: return "EXIT_APPLICATION";
                    case NEW_INTENT: return "NEW_INTENT";
                    case RECEIVER: return "RECEIVER";
                    case CREATE_SERVICE: return "CREATE_SERVICE";
                    case SERVICE_ARGS: return "SERVICE_ARGS";
                    case STOP_SERVICE: return "STOP_SERVICE";
                    case CONFIGURATION_CHANGED: return "CONFIGURATION_CHANGED";
                    case CLEAN_UP_CONTEXT: return "CLEAN_UP_CONTEXT";
                    case GC_WHEN_IDLE: return "GC_WHEN_IDLE";
                    case BIND_SERVICE: return "BIND_SERVICE";
                    case UNBIND_SERVICE: return "UNBIND_SERVICE";
                    case DUMP_SERVICE: return "DUMP_SERVICE";
                    case LOW_MEMORY: return "LOW_MEMORY";
                    case ACTIVITY_CONFIGURATION_CHANGED: return "ACTIVITY_CONFIGURATION_CHANGED";
                    case ACTIVITY_MOVED_TO_DISPLAY: return "ACTIVITY_MOVED_TO_DISPLAY";
                    case RELAUNCH_ACTIVITY: return "RELAUNCH_ACTIVITY";
                    case PROFILER_CONTROL: return "PROFILER_CONTROL";
                    case CREATE_BACKUP_AGENT: return "CREATE_BACKUP_AGENT";
                    case DESTROY_BACKUP_AGENT: return "DESTROY_BACKUP_AGENT";
                    case SUICIDE: return "SUICIDE";
                    case REMOVE_PROVIDER: return "REMOVE_PROVIDER";
                    case ENABLE_JIT: return "ENABLE_JIT";
                    case DISPATCH_PACKAGE_BROADCAST: return "DISPATCH_PACKAGE_BROADCAST";
                    case SCHEDULE_CRASH: return "SCHEDULE_CRASH";
                    case DUMP_HEAP: return "DUMP_HEAP";
                    case DUMP_ACTIVITY: return "DUMP_ACTIVITY";
                    case SLEEPING: return "SLEEPING";
                    case SET_CORE_SETTINGS: return "SET_CORE_SETTINGS";
                    case UPDATE_PACKAGE_COMPATIBILITY_INFO: return "UPDATE_PACKAGE_COMPATIBILITY_INFO";
                    case TRIM_MEMORY: return "TRIM_MEMORY";
                    case DUMP_PROVIDER: return "DUMP_PROVIDER";
                    case UNSTABLE_PROVIDER_DIED: return "UNSTABLE_PROVIDER_DIED";
                    case REQUEST_ASSIST_CONTEXT_EXTRAS: return "REQUEST_ASSIST_CONTEXT_EXTRAS";
                    case TRANSLUCENT_CONVERSION_COMPLETE: return "TRANSLUCENT_CONVERSION_COMPLETE";
                    case INSTALL_PROVIDER: return "INSTALL_PROVIDER";
                    case ON_NEW_ACTIVITY_OPTIONS: return "ON_NEW_ACTIVITY_OPTIONS";
                    case CANCEL_VISIBLE_BEHIND: return "CANCEL_VISIBLE_BEHIND";
                    case BACKGROUND_VISIBLE_BEHIND_CHANGED: return "BACKGROUND_VISIBLE_BEHIND_CHANGED";
                    case ENTER_ANIMATION_COMPLETE: return "ENTER_ANIMATION_COMPLETE";
                    case MULTI_WINDOW_MODE_CHANGED: return "MULTI_WINDOW_MODE_CHANGED";
                    case PICTURE_IN_PICTURE_MODE_CHANGED: return "PICTURE_IN_PICTURE_MODE_CHANGED";
                    case LOCAL_VOICE_INTERACTION_STARTED: return "LOCAL_VOICE_INTERACTION_STARTED";
                    case ATTACH_AGENT: return "ATTACH_AGENT";
                    case APPLICATION_INFO_CHANGED: return "APPLICATION_INFO_CHANGED";
                }
            }
            return Integer.toString(code);
        }
        public void handleMessage(Message msg) {
            if (DEBUG_MESSAGES) Slog.v(TAG, ">>> handling: " + codeToString(msg.what));
            switch (msg.what) {
                case LAUNCH_ACTIVITY: {
                    Trace.traceBegin(Trace.TRACE_TAG_ACTIVITY_MANAGER, "activityStart");
                    final ActivityClientRecord r = (ActivityClientRecord) msg.obj;

                    r.packageInfo = getPackageInfoNoCheck(
                            r.activityInfo.applicationInfo, r.compatInfo);
                    handleLaunchActivity(r, null, "LAUNCH_ACTIVITY");
                    Trace.traceEnd(Trace.TRACE_TAG_ACTIVITY_MANAGER);
                } break;
                case RELAUNCH_ACTIVITY: {
                    Trace.traceBegin(Trace.TRACE_TAG_ACTIVITY_MANAGER, "activityRestart");
                    ActivityClientRecord r = (ActivityClientRecord)msg.obj;
                    handleRelaunchActivity(r);
                    Trace.traceEnd(Trace.TRACE_TAG_ACTIVITY_MANAGER);
                } break;
                case PAUSE_ACTIVITY: {
                    Trace.traceBegin(Trace.TRACE_TAG_ACTIVITY_MANAGER, "activityPause");
                    SomeArgs args = (SomeArgs) msg.obj;
                    handlePauseActivity((IBinder) args.arg1, false,
                            (args.argi1 & USER_LEAVING) != 0, args.argi2,
                            (args.argi1 & DONT_REPORT) != 0, args.argi3);
                    maybeSnapshot();
                    Trace.traceEnd(Trace.TRACE_TAG_ACTIVITY_MANAGER);
                } break;
                case PAUSE_ACTIVITY_FINISHING: {
                    Trace.traceBegin(Trace.TRACE_TAG_ACTIVITY_MANAGER, "activityPause");
                    SomeArgs args = (SomeArgs) msg.obj;
                    handlePauseActivity((IBinder) args.arg1, true, (args.argi1 & USER_LEAVING) != 0,
                            args.argi2, (args.argi1 & DONT_REPORT) != 0, args.argi3);
                    Trace.traceEnd(Trace.TRACE_TAG_ACTIVITY_MANAGER);
                } break;
                case STOP_ACTIVITY_SHOW: {
                    Trace.traceBegin(Trace.TRACE_TAG_ACTIVITY_MANAGER, "activityStop");
                    SomeArgs args = (SomeArgs) msg.obj;
                    handleStopActivity((IBinder) args.arg1, true, args.argi2, args.argi3);
                    Trace.traceEnd(Trace.TRACE_TAG_ACTIVITY_MANAGER);
                } break;
                case STOP_ACTIVITY_HIDE: {
                    Trace.traceBegin(Trace.TRACE_TAG_ACTIVITY_MANAGER, "activityStop");
                    SomeArgs args = (SomeArgs) msg.obj;
                    handleStopActivity((IBinder) args.arg1, false, args.argi2, args.argi3);
                    Trace.traceEnd(Trace.TRACE_TAG_ACTIVITY_MANAGER);
                } break;
                case SHOW_WINDOW:
                    Trace.traceBegin(Trace.TRACE_TAG_ACTIVITY_MANAGER, "activityShowWindow");
                    handleWindowVisibility((IBinder)msg.obj, true);
                    Trace.traceEnd(Trace.TRACE_TAG_ACTIVITY_MANAGER);
                    break;
                case HIDE_WINDOW:
                    Trace.traceBegin(Trace.TRACE_TAG_ACTIVITY_MANAGER, "activityHideWindow");
                    handleWindowVisibility((IBinder)msg.obj, false);
                    Trace.traceEnd(Trace.TRACE_TAG_ACTIVITY_MANAGER);
                    break;
                case RESUME_ACTIVITY:
                    Trace.traceBegin(Trace.TRACE_TAG_ACTIVITY_MANAGER, "activityResume");
                    SomeArgs args = (SomeArgs) msg.obj;
                    handleResumeActivity((IBinder) args.arg1, true, args.argi1 != 0, true,
                            args.argi3, "RESUME_ACTIVITY");
                    Trace.traceEnd(Trace.TRACE_TAG_ACTIVITY_MANAGER);
                    break;
                case SEND_RESULT:
                    Trace.traceBegin(Trace.TRACE_TAG_ACTIVITY_MANAGER, "activityDeliverResult");
                    handleSendResult((ResultData)msg.obj);
                    Trace.traceEnd(Trace.TRACE_TAG_ACTIVITY_MANAGER);
                    break;
                case DESTROY_ACTIVITY:
                    Trace.traceBegin(Trace.TRACE_TAG_ACTIVITY_MANAGER, "activityDestroy");
                    handleDestroyActivity((IBinder)msg.obj, msg.arg1 != 0,
                            msg.arg2, false);
                    Trace.traceEnd(Trace.TRACE_TAG_ACTIVITY_MANAGER);
                    break;
                case BIND_APPLICATION:
                    Trace.traceBegin(Trace.TRACE_TAG_ACTIVITY_MANAGER, "bindApplication");
                    AppBindData data = (AppBindData)msg.obj;
                    handleBindApplication(data);
                    Trace.traceEnd(Trace.TRACE_TAG_ACTIVITY_MANAGER);
                    break;
                case EXIT_APPLICATION:
                    if (mInitialApplication != null) {
                        mInitialApplication.onTerminate();
                    }
                    Looper.myLooper().quit();
                    break;
                case NEW_INTENT:
                    Trace.traceBegin(Trace.TRACE_TAG_ACTIVITY_MANAGER, "activityNewIntent");
                    handleNewIntent((NewIntentData)msg.obj);
                    Trace.traceEnd(Trace.TRACE_TAG_ACTIVITY_MANAGER);
                    break;
                case RECEIVER:
                    Trace.traceBegin(Trace.TRACE_TAG_ACTIVITY_MANAGER, "broadcastReceiveComp");
                    handleReceiver((ReceiverData)msg.obj);
                    maybeSnapshot();
                    Trace.traceEnd(Trace.TRACE_TAG_ACTIVITY_MANAGER);
                    break;
                case CREATE_SERVICE:
                    Trace.traceBegin(Trace.TRACE_TAG_ACTIVITY_MANAGER, ("serviceCreate: " + String.valueOf(msg.obj)));
                    handleCreateService((CreateServiceData)msg.obj);
                    Trace.traceEnd(Trace.TRACE_TAG_ACTIVITY_MANAGER);
                    break;
                case BIND_SERVICE:
                    Trace.traceBegin(Trace.TRACE_TAG_ACTIVITY_MANAGER, "serviceBind");
                    handleBindService((BindServiceData)msg.obj);
                    Trace.traceEnd(Trace.TRACE_TAG_ACTIVITY_MANAGER);
                    break;
                case UNBIND_SERVICE:
                    Trace.traceBegin(Trace.TRACE_TAG_ACTIVITY_MANAGER, "serviceUnbind");
                    handleUnbindService((BindServiceData)msg.obj);
                    Trace.traceEnd(Trace.TRACE_TAG_ACTIVITY_MANAGER);
                    break;
                case SERVICE_ARGS:
                    Trace.traceBegin(Trace.TRACE_TAG_ACTIVITY_MANAGER, ("serviceStart: " + String.valueOf(msg.obj)));
                    handleServiceArgs((ServiceArgsData)msg.obj);
                    Trace.traceEnd(Trace.TRACE_TAG_ACTIVITY_MANAGER);
                    break;
                case STOP_SERVICE:
                    Trace.traceBegin(Trace.TRACE_TAG_ACTIVITY_MANAGER, "serviceStop");
                    handleStopService((IBinder)msg.obj);
                    maybeSnapshot();
                    Trace.traceEnd(Trace.TRACE_TAG_ACTIVITY_MANAGER);
                    break;
                case CONFIGURATION_CHANGED:
                    Trace.traceBegin(Trace.TRACE_TAG_ACTIVITY_MANAGER, "configChanged");
                    mCurDefaultDisplayDpi = ((Configuration)msg.obj).densityDpi;
                    mUpdatingSystemConfig = true;
                    try {
                        handleConfigurationChanged((Configuration) msg.obj, null);
                    } finally {
                        mUpdatingSystemConfig = false;
                    }
                    Trace.traceEnd(Trace.TRACE_TAG_ACTIVITY_MANAGER);
                    break;
                case CLEAN_UP_CONTEXT:
                    ContextCleanupInfo cci = (ContextCleanupInfo)msg.obj;
                    cci.context.performFinalCleanup(cci.who, cci.what);
                    break;
                case GC_WHEN_IDLE:
                    scheduleGcIdler();
                    break;
                case DUMP_SERVICE:
                    handleDumpService((DumpComponentInfo)msg.obj);
                    break;
                case LOW_MEMORY:
                    Trace.traceBegin(Trace.TRACE_TAG_ACTIVITY_MANAGER, "lowMemory");
                    handleLowMemory();
                    Trace.traceEnd(Trace.TRACE_TAG_ACTIVITY_MANAGER);
                    break;
                case ACTIVITY_CONFIGURATION_CHANGED:
                    Trace.traceBegin(Trace.TRACE_TAG_ACTIVITY_MANAGER, "activityConfigChanged");
                    handleActivityConfigurationChanged((ActivityConfigChangeData) msg.obj,
                            INVALID_DISPLAY);
                    Trace.traceEnd(Trace.TRACE_TAG_ACTIVITY_MANAGER);
                    break;
                case ACTIVITY_MOVED_TO_DISPLAY:
                    Trace.traceBegin(Trace.TRACE_TAG_ACTIVITY_MANAGER, "activityMovedToDisplay");
                    handleActivityConfigurationChanged((ActivityConfigChangeData) msg.obj,
                            msg.arg1 /* displayId */);
                    Trace.traceEnd(Trace.TRACE_TAG_ACTIVITY_MANAGER);
                    break;
                case PROFILER_CONTROL:
                    handleProfilerControl(msg.arg1 != 0, (ProfilerInfo)msg.obj, msg.arg2);
                    break;
                case CREATE_BACKUP_AGENT:
                    Trace.traceBegin(Trace.TRACE_TAG_ACTIVITY_MANAGER, "backupCreateAgent");
                    handleCreateBackupAgent((CreateBackupAgentData)msg.obj);
                    Trace.traceEnd(Trace.TRACE_TAG_ACTIVITY_MANAGER);
                    break;
                case DESTROY_BACKUP_AGENT:
                    Trace.traceBegin(Trace.TRACE_TAG_ACTIVITY_MANAGER, "backupDestroyAgent");
                    handleDestroyBackupAgent((CreateBackupAgentData)msg.obj);
                    Trace.traceEnd(Trace.TRACE_TAG_ACTIVITY_MANAGER);
                    break;
                case SUICIDE:
                    Process.killProcess(Process.myPid());
                    break;
                case REMOVE_PROVIDER:
                    Trace.traceBegin(Trace.TRACE_TAG_ACTIVITY_MANAGER, "providerRemove");
                    completeRemoveProvider((ProviderRefCount)msg.obj);
                    Trace.traceEnd(Trace.TRACE_TAG_ACTIVITY_MANAGER);
                    break;
                case ENABLE_JIT:
                    ensureJitEnabled();
                    break;
                case DISPATCH_PACKAGE_BROADCAST:
                    Trace.traceBegin(Trace.TRACE_TAG_ACTIVITY_MANAGER, "broadcastPackage");
                    handleDispatchPackageBroadcast(msg.arg1, (String[])msg.obj);
                    Trace.traceEnd(Trace.TRACE_TAG_ACTIVITY_MANAGER);
                    break;
                case SCHEDULE_CRASH:
                    throw new RemoteServiceException((String)msg.obj);
                case DUMP_HEAP:
                    handleDumpHeap(msg.arg1 != 0, (DumpHeapData)msg.obj);
                    break;
                case DUMP_ACTIVITY:
                    handleDumpActivity((DumpComponentInfo)msg.obj);
                    break;
                case DUMP_PROVIDER:
                    handleDumpProvider((DumpComponentInfo)msg.obj);
                    break;
                case SLEEPING:
                    Trace.traceBegin(Trace.TRACE_TAG_ACTIVITY_MANAGER, "sleeping");
                    handleSleeping((IBinder)msg.obj, msg.arg1 != 0);
                    Trace.traceEnd(Trace.TRACE_TAG_ACTIVITY_MANAGER);
                    break;
                case SET_CORE_SETTINGS:
                    Trace.traceBegin(Trace.TRACE_TAG_ACTIVITY_MANAGER, "setCoreSettings");
                    handleSetCoreSettings((Bundle) msg.obj);
                    Trace.traceEnd(Trace.TRACE_TAG_ACTIVITY_MANAGER);
                    break;
                case UPDATE_PACKAGE_COMPATIBILITY_INFO:
                    handleUpdatePackageCompatibilityInfo((UpdateCompatibilityData)msg.obj);
                    break;
                case TRIM_MEMORY:
                    Trace.traceBegin(Trace.TRACE_TAG_ACTIVITY_MANAGER, "trimMemory");
                    handleTrimMemory(msg.arg1);
                    Trace.traceEnd(Trace.TRACE_TAG_ACTIVITY_MANAGER);
                    break;
                case UNSTABLE_PROVIDER_DIED:
                    handleUnstableProviderDied((IBinder)msg.obj, false);
                    break;
                case REQUEST_ASSIST_CONTEXT_EXTRAS:
                    handleRequestAssistContextExtras((RequestAssistContextExtras)msg.obj);
                    break;
                case TRANSLUCENT_CONVERSION_COMPLETE:
                    handleTranslucentConversionComplete((IBinder)msg.obj, msg.arg1 == 1);
                    break;
                case INSTALL_PROVIDER:
                    handleInstallProvider((ProviderInfo) msg.obj);
                    break;
                case ON_NEW_ACTIVITY_OPTIONS:
                    Pair<IBinder, ActivityOptions> pair = (Pair<IBinder, ActivityOptions>) msg.obj;
                    onNewActivityOptions(pair.first, pair.second);
                    break;
                case CANCEL_VISIBLE_BEHIND:
                    handleCancelVisibleBehind((IBinder) msg.obj);
                    break;
                case BACKGROUND_VISIBLE_BEHIND_CHANGED:
                    handleOnBackgroundVisibleBehindChanged((IBinder) msg.obj, msg.arg1 > 0);
                    break;
                case ENTER_ANIMATION_COMPLETE:
                    handleEnterAnimationComplete((IBinder) msg.obj);
                    break;
                case START_BINDER_TRACKING:
                    handleStartBinderTracking();
                    break;
                case STOP_BINDER_TRACKING_AND_DUMP:
                    handleStopBinderTrackingAndDump((ParcelFileDescriptor) msg.obj);
                    break;
                case MULTI_WINDOW_MODE_CHANGED:
                    handleMultiWindowModeChanged((IBinder) ((SomeArgs) msg.obj).arg1,
                            ((SomeArgs) msg.obj).argi1 == 1,
                            (Configuration) ((SomeArgs) msg.obj).arg2);
                    break;
                case PICTURE_IN_PICTURE_MODE_CHANGED:
                    handlePictureInPictureModeChanged((IBinder) ((SomeArgs) msg.obj).arg1,
                            ((SomeArgs) msg.obj).argi1 == 1,
                            (Configuration) ((SomeArgs) msg.obj).arg2);
                    break;
                case LOCAL_VOICE_INTERACTION_STARTED:
                    handleLocalVoiceInteractionStarted((IBinder) ((SomeArgs) msg.obj).arg1,
                            (IVoiceInteractor) ((SomeArgs) msg.obj).arg2);
                    break;
                case ATTACH_AGENT:
                    handleAttachAgent((String) msg.obj);
                    break;
                case APPLICATION_INFO_CHANGED:
                    mUpdatingSystemConfig = true;
                    try {
                        handleApplicationInfoChanged((ApplicationInfo) msg.obj);
                    } finally {
                        mUpdatingSystemConfig = false;
                    }
                    break;
            }
            Object obj = msg.obj;
            if (obj instanceof SomeArgs) {
                ((SomeArgs) obj).recycle();
            }
            if (DEBUG_MESSAGES) Slog.v(TAG, "<<< done: " + codeToString(msg.what));
        }

        private void maybeSnapshot() {
            if (mBoundApplication != null && SamplingProfilerIntegration.isEnabled()) {
                // convert the *private* ActivityThread.PackageInfo to *public* known
                // android.content.pm.PackageInfo
                String packageName = mBoundApplication.info.mPackageName;
                android.content.pm.PackageInfo packageInfo = null;
                try {
                    Context context = getSystemContext();
                    if(context == null) {
                        Log.e(TAG, "cannot get a valid context");
                        return;
                    }
                    PackageManager pm = context.getPackageManager();
                    if(pm == null) {
                        Log.e(TAG, "cannot get a valid PackageManager");
                        return;
                    }
                    packageInfo = pm.getPackageInfo(
                            packageName, PackageManager.GET_ACTIVITIES);
                } catch (NameNotFoundException e) {
                    Log.e(TAG, "cannot get package info for " + packageName, e);
                }
                SamplingProfilerIntegration.writeSnapshot(mBoundApplication.processName, packageInfo);
            }
        }
    }
}

系统如何控制进程

ActivityThread类持有唯一的ApplicationThread应用线程类,系统服务可以通过调用该类接口,进而触发H类主线程执行,从而达到控制进程的主线程执行。

ApplicationThread:继承aidl的接口,由系统服务远程调度对应方法,进而控制进程内主线程的执行。例如在启动一个activity时,ActivityManager会将ApplicationThread唯一对象传递到activity管理服务端,然后管理服务端进而控制进程activity的生命周期:
int result = ActivityManager.getService()
.startActivities(whoThread, who.getBasePackageName(), intents, resolvedTypes,
token, options, userId);

ApplicationThread内部实现相关方法:

private class ApplicationThread extends IApplicationThread.Stub {
    private static final String DB_INFO_FORMAT = "  %8s %8s %14s %14s  %s";

    private int mLastProcessState = -1;

    private void updatePendingConfiguration(Configuration config) {
        synchronized (mResourcesManager) {
            if (mPendingConfiguration == null ||
                    mPendingConfiguration.isOtherSeqNewer(config)) {
                mPendingConfiguration = config;
            }
        }
    }

    public final void schedulePauseActivity(IBinder token, boolean finished,
            boolean userLeaving, int configChanges, boolean dontReport) {
        int seq = getLifecycleSeq();
        if (DEBUG_ORDER) Slog.d(TAG, "pauseActivity " + ActivityThread.this
                + " operation received seq: " + seq);
        sendMessage(
                finished ? H.PAUSE_ACTIVITY_FINISHING : H.PAUSE_ACTIVITY,
                token,
                (userLeaving ? USER_LEAVING : 0) | (dontReport ? DONT_REPORT : 0),
                configChanges,
                seq);
    }

    public final void scheduleStopActivity(IBinder token, boolean showWindow,
            int configChanges) {
        int seq = getLifecycleSeq();
        if (DEBUG_ORDER) Slog.d(TAG, "stopActivity " + ActivityThread.this
                + " operation received seq: " + seq);
        sendMessage(
            showWindow ? H.STOP_ACTIVITY_SHOW : H.STOP_ACTIVITY_HIDE,
            token, 0, configChanges, seq);
    }

    public final void scheduleWindowVisibility(IBinder token, boolean showWindow) {
        sendMessage(
            showWindow ? H.SHOW_WINDOW : H.HIDE_WINDOW,
            token);
    }

    public final void scheduleSleeping(IBinder token, boolean sleeping) {
        sendMessage(H.SLEEPING, token, sleeping ? 1 : 0);
    }

    public final void scheduleResumeActivity(IBinder token, int processState,
            boolean isForward, Bundle resumeArgs) {
        int seq = getLifecycleSeq();
        if (DEBUG_ORDER) Slog.d(TAG, "resumeActivity " + ActivityThread.this
                + " operation received seq: " + seq);
        updateProcessState(processState, false);
        sendMessage(H.RESUME_ACTIVITY, token, isForward ? 1 : 0, 0, seq);
    }

    public final void scheduleSendResult(IBinder token, List<ResultInfo> results) {
        ResultData res = new ResultData();
        res.token = token;
        res.results = results;
        sendMessage(H.SEND_RESULT, res);
    }

    // we use token to identify this activity without having to send the
    // activity itself back to the activity manager. (matters more with ipc)
    @Override
    public final void scheduleLaunchActivity(Intent intent, IBinder token, int ident,
            ActivityInfo info, Configuration curConfig, Configuration overrideConfig,
            CompatibilityInfo compatInfo, String referrer, IVoiceInteractor voiceInteractor,
            int procState, Bundle state, PersistableBundle persistentState,
            List<ResultInfo> pendingResults, List<ReferrerIntent> pendingNewIntents,
            boolean notResumed, boolean isForward, ProfilerInfo profilerInfo) {

        updateProcessState(procState, false);

        ActivityClientRecord r = new ActivityClientRecord();

        r.token = token;
        r.ident = ident;
        r.intent = intent;
        r.referrer = referrer;
        r.voiceInteractor = voiceInteractor;
        r.activityInfo = info;
        r.compatInfo = compatInfo;
        r.state = state;
        r.persistentState = persistentState;

        r.pendingResults = pendingResults;
        r.pendingIntents = pendingNewIntents;

        r.startsNotResumed = notResumed;
        r.isForward = isForward;

        r.profilerInfo = profilerInfo;

        r.overrideConfig = overrideConfig;
        updatePendingConfiguration(curConfig);

        sendMessage(H.LAUNCH_ACTIVITY, r);
    }

    @Override
    public final void scheduleRelaunchActivity(IBinder token,
            List<ResultInfo> pendingResults, List<ReferrerIntent> pendingNewIntents,
            int configChanges, boolean notResumed, Configuration config,
            Configuration overrideConfig, boolean preserveWindow) {
        requestRelaunchActivity(token, pendingResults, pendingNewIntents,
                configChanges, notResumed, config, overrideConfig, true, preserveWindow);
    }

    public final void scheduleNewIntent(
            List<ReferrerIntent> intents, IBinder token, boolean andPause) {
        NewIntentData data = new NewIntentData();
        data.intents = intents;
        data.token = token;
        data.andPause = andPause;

        sendMessage(H.NEW_INTENT, data);
    }

    public final void scheduleDestroyActivity(IBinder token, boolean finishing,
            int configChanges) {
        sendMessage(H.DESTROY_ACTIVITY, token, finishing ? 1 : 0,
                configChanges);
    }

    public final void scheduleReceiver(Intent intent, ActivityInfo info,
            CompatibilityInfo compatInfo, int resultCode, String data, Bundle extras,
            boolean sync, int sendingUser, int processState) {
        updateProcessState(processState, false);
        ReceiverData r = new ReceiverData(intent, resultCode, data, extras,
                sync, false, mAppThread.asBinder(), sendingUser);
        r.info = info;
        r.compatInfo = compatInfo;
        sendMessage(H.RECEIVER, r);
    }

    public final void scheduleCreateBackupAgent(ApplicationInfo app,
            CompatibilityInfo compatInfo, int backupMode) {
        CreateBackupAgentData d = new CreateBackupAgentData();
        d.appInfo = app;
        d.compatInfo = compatInfo;
        d.backupMode = backupMode;

        sendMessage(H.CREATE_BACKUP_AGENT, d);
    }

    public final void scheduleDestroyBackupAgent(ApplicationInfo app,
            CompatibilityInfo compatInfo) {
        CreateBackupAgentData d = new CreateBackupAgentData();
        d.appInfo = app;
        d.compatInfo = compatInfo;

        sendMessage(H.DESTROY_BACKUP_AGENT, d);
    }

    public final void scheduleCreateService(IBinder token,
            ServiceInfo info, CompatibilityInfo compatInfo, int processState) {
        updateProcessState(processState, false);
        CreateServiceData s = new CreateServiceData();
        s.token = token;
        s.info = info;
        s.compatInfo = compatInfo;

        sendMessage(H.CREATE_SERVICE, s);
    }

    public final void scheduleBindService(IBinder token, Intent intent,
            boolean rebind, int processState) {
        updateProcessState(processState, false);
        BindServiceData s = new BindServiceData();
        s.token = token;
        s.intent = intent;
        s.rebind = rebind;

        if (DEBUG_SERVICE)
            Slog.v(TAG, "scheduleBindService token=" + token + " intent=" + intent + " uid="
                    + Binder.getCallingUid() + " pid=" + Binder.getCallingPid());
        sendMessage(H.BIND_SERVICE, s);
    }

    public final void scheduleUnbindService(IBinder token, Intent intent) {
        BindServiceData s = new BindServiceData();
        s.token = token;
        s.intent = intent;

        sendMessage(H.UNBIND_SERVICE, s);
    }

    public final void scheduleServiceArgs(IBinder token, ParceledListSlice args) {
        List<ServiceStartArgs> list = args.getList();

        for (int i = 0; i < list.size(); i++) {
            ServiceStartArgs ssa = list.get(i);
            ServiceArgsData s = new ServiceArgsData();
            s.token = token;
            s.taskRemoved = ssa.taskRemoved;
            s.startId = ssa.startId;
            s.flags = ssa.flags;
            s.args = ssa.args;

            sendMessage(H.SERVICE_ARGS, s);
        }
    }

    public final void scheduleStopService(IBinder token) {
        sendMessage(H.STOP_SERVICE, token);
    }

    public final void bindApplication(String processName, ApplicationInfo appInfo,
            List<ProviderInfo> providers, ComponentName instrumentationName,
            ProfilerInfo profilerInfo, Bundle instrumentationArgs,
            IInstrumentationWatcher instrumentationWatcher,
            IUiAutomationConnection instrumentationUiConnection, int debugMode,
            boolean enableBinderTracking, boolean trackAllocation,
            boolean isRestrictedBackupMode, boolean persistent, Configuration config,
            CompatibilityInfo compatInfo, Map services, Bundle coreSettings,
            String buildSerial) {

        if (services != null) {
            // Setup the service cache in the ServiceManager
            ServiceManager.initServiceCache(services);
        }

        setCoreSettings(coreSettings);

        AppBindData data = new AppBindData();
        data.processName = processName;
        data.appInfo = appInfo;
        data.providers = providers;
        data.instrumentationName = instrumentationName;
        data.instrumentationArgs = instrumentationArgs;
        data.instrumentationWatcher = instrumentationWatcher;
        data.instrumentationUiAutomationConnection = instrumentationUiConnection;
        data.debugMode = debugMode;
        data.enableBinderTracking = enableBinderTracking;
        data.trackAllocation = trackAllocation;
        data.restrictedBackupMode = isRestrictedBackupMode;
        data.persistent = persistent;
        data.config = config;
        data.compatInfo = compatInfo;
        data.initProfilerInfo = profilerInfo;
        data.buildSerial = buildSerial;
        sendMessage(H.BIND_APPLICATION, data);
    }

    public final void scheduleExit() {
        sendMessage(H.EXIT_APPLICATION, null);
    }

    public final void scheduleSuicide() {
        sendMessage(H.SUICIDE, null);
    }

    public void scheduleConfigurationChanged(Configuration config) {
        updatePendingConfiguration(config);
        sendMessage(H.CONFIGURATION_CHANGED, config);
    }

    public void scheduleApplicationInfoChanged(ApplicationInfo ai) {
        sendMessage(H.APPLICATION_INFO_CHANGED, ai);
    }

    public void updateTimeZone() {
        TimeZone.setDefault(null);
    }

    public void clearDnsCache() {
        // a non-standard API to get this to libcore
        InetAddress.clearDnsCache();
        // Allow libcore to perform the necessary actions as it sees fit upon a network
        // configuration change.
        NetworkEventDispatcher.getInstance().onNetworkConfigurationChanged();
    }

    public void setHttpProxy(String host, String port, String exclList, Uri pacFileUrl) {
        final ConnectivityManager cm = ConnectivityManager.from(getSystemContext());
        final Network network = cm.getBoundNetworkForProcess();
        if (network != null) {
            Proxy.setHttpProxySystemProperty(cm.getDefaultProxy());
        } else {
            Proxy.setHttpProxySystemProperty(host, port, exclList, pacFileUrl);
        }
    }

    public void processInBackground() {
        mH.removeMessages(H.GC_WHEN_IDLE);
        mH.sendMessage(mH.obtainMessage(H.GC_WHEN_IDLE));
    }

    public void dumpService(ParcelFileDescriptor pfd, IBinder servicetoken, String[] args) {
        DumpComponentInfo data = new DumpComponentInfo();
        try {
            data.fd = pfd.dup();
            data.token = servicetoken;
            data.args = args;
            sendMessage(H.DUMP_SERVICE, data, 0, 0, true /*async*/);
        } catch (IOException e) {
            Slog.w(TAG, "dumpService failed", e);
        } finally {
            IoUtils.closeQuietly(pfd);
        }
    }

    // This function exists to make sure all receiver dispatching is
    // correctly ordered, since these are one-way calls and the binder driver
    // applies transaction ordering per object for such calls.
    public void scheduleRegisteredReceiver(IIntentReceiver receiver, Intent intent,
            int resultCode, String dataStr, Bundle extras, boolean ordered,
            boolean sticky, int sendingUser, int processState) throws RemoteException {
        updateProcessState(processState, false);
        receiver.performReceive(intent, resultCode, dataStr, extras, ordered,
                sticky, sendingUser);
    }

    @Override
    public void scheduleLowMemory() {
        sendMessage(H.LOW_MEMORY, null);
    }

    @Override
    public void scheduleActivityConfigurationChanged(
            IBinder token, Configuration overrideConfig) {
        sendMessage(H.ACTIVITY_CONFIGURATION_CHANGED,
                new ActivityConfigChangeData(token, overrideConfig));
    }

    @Override
    public void scheduleActivityMovedToDisplay(IBinder token, int displayId,
            Configuration overrideConfig) {
        sendMessage(H.ACTIVITY_MOVED_TO_DISPLAY,
                new ActivityConfigChangeData(token, overrideConfig), displayId);
    }

    @Override
    public void profilerControl(boolean start, ProfilerInfo profilerInfo, int profileType) {
        sendMessage(H.PROFILER_CONTROL, profilerInfo, start ? 1 : 0, profileType);
    }

    public void dumpHeap(boolean managed, String path, ParcelFileDescriptor fd) {
        DumpHeapData dhd = new DumpHeapData();
        dhd.path = path;
        dhd.fd = fd;
        sendMessage(H.DUMP_HEAP, dhd, managed ? 1 : 0, 0, true /*async*/);
    }

    public void attachAgent(String agent) {
        sendMessage(H.ATTACH_AGENT, agent);
    }

    public void setSchedulingGroup(int group) {
        // Note: do this immediately, since going into the foreground
        // should happen regardless of what pending work we have to do
        // and the activity manager will wait for us to report back that
        // we are done before sending us to the background.
        try {
            Process.setProcessGroup(Process.myPid(), group);
        } catch (Exception e) {
            Slog.w(TAG, "Failed setting process group to " + group, e);
        }
    }

    public void dispatchPackageBroadcast(int cmd, String[] packages) {
        sendMessage(H.DISPATCH_PACKAGE_BROADCAST, packages, cmd);
    }

    public void scheduleCrash(String msg) {
        sendMessage(H.SCHEDULE_CRASH, msg);
    }

    public void dumpActivity(ParcelFileDescriptor pfd, IBinder activitytoken,
            String prefix, String[] args) {
        DumpComponentInfo data = new DumpComponentInfo();
        try {
            data.fd = pfd.dup();
            data.token = activitytoken;
            data.prefix = prefix;
            data.args = args;
            sendMessage(H.DUMP_ACTIVITY, data, 0, 0, true /*async*/);
        } catch (IOException e) {
            Slog.w(TAG, "dumpActivity failed", e);
        } finally {
            IoUtils.closeQuietly(pfd);
        }
    }

    public void dumpProvider(ParcelFileDescriptor pfd, IBinder providertoken,
            String[] args) {
        DumpComponentInfo data = new DumpComponentInfo();
        try {
            data.fd = pfd.dup();
            data.token = providertoken;
            data.args = args;
            sendMessage(H.DUMP_PROVIDER, data, 0, 0, true /*async*/);
        } catch (IOException e) {
            Slog.w(TAG, "dumpProvider failed", e);
        } finally {
            IoUtils.closeQuietly(pfd);
        }
    }

    @Override
    public void dumpMemInfo(ParcelFileDescriptor pfd, Debug.MemoryInfo mem, boolean checkin,
            boolean dumpFullInfo, boolean dumpDalvik, boolean dumpSummaryOnly,
            boolean dumpUnreachable, String[] args) {
        FileOutputStream fout = new FileOutputStream(pfd.getFileDescriptor());
        PrintWriter pw = new FastPrintWriter(fout);
        try {
            dumpMemInfo(pw, mem, checkin, dumpFullInfo, dumpDalvik, dumpSummaryOnly, dumpUnreachable);
        } finally {
            pw.flush();
            IoUtils.closeQuietly(pfd);
        }
    }

    private void dumpMemInfo(PrintWriter pw, Debug.MemoryInfo memInfo, boolean checkin,
            boolean dumpFullInfo, boolean dumpDalvik, boolean dumpSummaryOnly, boolean dumpUnreachable) {
        long nativeMax = Debug.getNativeHeapSize() / 1024;
        long nativeAllocated = Debug.getNativeHeapAllocatedSize() / 1024;
        long nativeFree = Debug.getNativeHeapFreeSize() / 1024;

        Runtime runtime = Runtime.getRuntime();
        runtime.gc();  // Do GC since countInstancesOfClass counts unreachable objects.
        long dalvikMax = runtime.totalMemory() / 1024;
        long dalvikFree = runtime.freeMemory() / 1024;
        long dalvikAllocated = dalvikMax - dalvikFree;

        Class[] classesToCount = new Class[] {
                ContextImpl.class,
                Activity.class,
                WebView.class,
                OpenSSLSocketImpl.class
        };
        long[] instanceCounts = VMDebug.countInstancesOfClasses(classesToCount, true);
        long appContextInstanceCount = instanceCounts[0];
        long activityInstanceCount = instanceCounts[1];
        long webviewInstanceCount = instanceCounts[2];
        long openSslSocketCount = instanceCounts[3];

        long viewInstanceCount = ViewDebug.getViewInstanceCount();
        long viewRootInstanceCount = ViewDebug.getViewRootImplCount();
        int globalAssetCount = AssetManager.getGlobalAssetCount();
        int globalAssetManagerCount = AssetManager.getGlobalAssetManagerCount();
        int binderLocalObjectCount = Debug.getBinderLocalObjectCount();
        int binderProxyObjectCount = Debug.getBinderProxyObjectCount();
        int binderDeathObjectCount = Debug.getBinderDeathObjectCount();
        long parcelSize = Parcel.getGlobalAllocSize();
        long parcelCount = Parcel.getGlobalAllocCount();
        SQLiteDebug.PagerStats stats = SQLiteDebug.getDatabaseInfo();

        dumpMemInfoTable(pw, memInfo, checkin, dumpFullInfo, dumpDalvik, dumpSummaryOnly,
                Process.myPid(),
                (mBoundApplication != null) ? mBoundApplication.processName : "unknown",
                nativeMax, nativeAllocated, nativeFree,
                dalvikMax, dalvikAllocated, dalvikFree);

        if (checkin) {
            // NOTE: if you change anything significant below, also consider changing
            // ACTIVITY_THREAD_CHECKIN_VERSION.

            // Object counts
            pw.print(viewInstanceCount); pw.print(',');
            pw.print(viewRootInstanceCount); pw.print(',');
            pw.print(appContextInstanceCount); pw.print(',');
            pw.print(activityInstanceCount); pw.print(',');

            pw.print(globalAssetCount); pw.print(',');
            pw.print(globalAssetManagerCount); pw.print(',');
            pw.print(binderLocalObjectCount); pw.print(',');
            pw.print(binderProxyObjectCount); pw.print(',');

            pw.print(binderDeathObjectCount); pw.print(',');
            pw.print(openSslSocketCount); pw.print(',');

            // SQL
            pw.print(stats.memoryUsed / 1024); pw.print(',');
            pw.print(stats.memoryUsed / 1024); pw.print(',');
            pw.print(stats.pageCacheOverflow / 1024); pw.print(',');
            pw.print(stats.largestMemAlloc / 1024);
            for (int i = 0; i < stats.dbStats.size(); i++) {
                DbStats dbStats = stats.dbStats.get(i);
                pw.print(','); pw.print(dbStats.dbName);
                pw.print(','); pw.print(dbStats.pageSize);
                pw.print(','); pw.print(dbStats.dbSize);
                pw.print(','); pw.print(dbStats.lookaside);
                pw.print(','); pw.print(dbStats.cache);
                pw.print(','); pw.print(dbStats.cache);
            }
            pw.println();

            return;
        }

        pw.println(" ");
        pw.println(" Objects");
        printRow(pw, TWO_COUNT_COLUMNS, "Views:", viewInstanceCount, "ViewRootImpl:",
                viewRootInstanceCount);

        printRow(pw, TWO_COUNT_COLUMNS, "AppContexts:", appContextInstanceCount,
                "Activities:", activityInstanceCount);

        printRow(pw, TWO_COUNT_COLUMNS, "Assets:", globalAssetCount,
                "AssetManagers:", globalAssetManagerCount);

        printRow(pw, TWO_COUNT_COLUMNS, "Local Binders:", binderLocalObjectCount,
                "Proxy Binders:", binderProxyObjectCount);
        printRow(pw, TWO_COUNT_COLUMNS, "Parcel memory:", parcelSize/1024,
                "Parcel count:", parcelCount);
        printRow(pw, TWO_COUNT_COLUMNS, "Death Recipients:", binderDeathObjectCount,
                "OpenSSL Sockets:", openSslSocketCount);
        printRow(pw, ONE_COUNT_COLUMN, "WebViews:", webviewInstanceCount);

        // SQLite mem info
        pw.println(" ");
        pw.println(" SQL");
        printRow(pw, ONE_COUNT_COLUMN, "MEMORY_USED:", stats.memoryUsed / 1024);
        printRow(pw, TWO_COUNT_COLUMNS, "PAGECACHE_OVERFLOW:",
                stats.pageCacheOverflow / 1024, "MALLOC_SIZE:", stats.largestMemAlloc / 1024);
        pw.println(" ");
        int N = stats.dbStats.size();
        if (N > 0) {
            pw.println(" DATABASES");
            printRow(pw, "  %8s %8s %14s %14s  %s", "pgsz", "dbsz", "Lookaside(b)", "cache",
                    "Dbname");
            for (int i = 0; i < N; i++) {
                DbStats dbStats = stats.dbStats.get(i);
                printRow(pw, DB_INFO_FORMAT,
                        (dbStats.pageSize > 0) ? String.valueOf(dbStats.pageSize) : " ",
                        (dbStats.dbSize > 0) ? String.valueOf(dbStats.dbSize) : " ",
                        (dbStats.lookaside > 0) ? String.valueOf(dbStats.lookaside) : " ",
                        dbStats.cache, dbStats.dbName);
            }
        }

        // Asset details.
        String assetAlloc = AssetManager.getAssetAllocations();
        if (assetAlloc != null) {
            pw.println(" ");
            pw.println(" Asset Allocations");
            pw.print(assetAlloc);
        }

        // Unreachable native memory
        if (dumpUnreachable) {
            boolean showContents = ((mBoundApplication != null)
                && ((mBoundApplication.appInfo.flags&ApplicationInfo.FLAG_DEBUGGABLE) != 0))
                || android.os.Build.IS_DEBUGGABLE;
            pw.println(" ");
            pw.println(" Unreachable memory");
            pw.print(Debug.getUnreachableMemory(100, showContents));
        }
    }

    @Override
    public void dumpGfxInfo(ParcelFileDescriptor pfd, String[] args) {
        nDumpGraphicsInfo(pfd.getFileDescriptor());
        WindowManagerGlobal.getInstance().dumpGfxInfo(pfd.getFileDescriptor(), args);
        IoUtils.closeQuietly(pfd);
    }

    private void dumpDatabaseInfo(ParcelFileDescriptor pfd, String[] args) {
        PrintWriter pw = new FastPrintWriter(
                new FileOutputStream(pfd.getFileDescriptor()));
        PrintWriterPrinter printer = new PrintWriterPrinter(pw);
        SQLiteDebug.dump(printer, args);
        pw.flush();
    }

    @Override
    public void dumpDbInfo(final ParcelFileDescriptor pfd, final String[] args) {
        if (mSystemThread) {
            // Ensure this invocation is asynchronous to prevent writer waiting if buffer cannot
            // be consumed. But it must duplicate the file descriptor first, since caller might
            // be closing it.
            final ParcelFileDescriptor dup;
            try {
                dup = pfd.dup();
            } catch (IOException e) {
                Log.w(TAG, "Could not dup FD " + pfd.getFileDescriptor().getInt$());
                return;
            } finally {
                IoUtils.closeQuietly(pfd);
            }

            AsyncTask.THREAD_POOL_EXECUTOR.execute(new Runnable() {
                @Override
                public void run() {
                    try {
                        dumpDatabaseInfo(dup, args);
                    } finally {
                        IoUtils.closeQuietly(dup);
                    }
                }
            });
        } else {
            dumpDatabaseInfo(pfd, args);
            IoUtils.closeQuietly(pfd);
        }
    }

    @Override
    public void unstableProviderDied(IBinder provider) {
        sendMessage(H.UNSTABLE_PROVIDER_DIED, provider);
    }

    @Override
    public void requestAssistContextExtras(IBinder activityToken, IBinder requestToken,
            int requestType, int sessionId, int flags) {
        RequestAssistContextExtras cmd = new RequestAssistContextExtras();
        cmd.activityToken = activityToken;
        cmd.requestToken = requestToken;
        cmd.requestType = requestType;
        cmd.sessionId = sessionId;
        cmd.flags = flags;
        sendMessage(H.REQUEST_ASSIST_CONTEXT_EXTRAS, cmd);
    }

    public void setCoreSettings(Bundle coreSettings) {
        sendMessage(H.SET_CORE_SETTINGS, coreSettings);
    }

    public void updatePackageCompatibilityInfo(String pkg, CompatibilityInfo info) {
        UpdateCompatibilityData ucd = new UpdateCompatibilityData();
        ucd.pkg = pkg;
        ucd.info = info;
        sendMessage(H.UPDATE_PACKAGE_COMPATIBILITY_INFO, ucd);
    }

    public void scheduleTrimMemory(int level) {
        sendMessage(H.TRIM_MEMORY, null, level);
    }

    public void scheduleTranslucentConversionComplete(IBinder token, boolean drawComplete) {
        sendMessage(H.TRANSLUCENT_CONVERSION_COMPLETE, token, drawComplete ? 1 : 0);
    }

    public void scheduleOnNewActivityOptions(IBinder token, Bundle options) {
        sendMessage(H.ON_NEW_ACTIVITY_OPTIONS,
                new Pair<IBinder, ActivityOptions>(token, ActivityOptions.fromBundle(options)));
    }

    public void setProcessState(int state) {
        updateProcessState(state, true);
    }

    public void updateProcessState(int processState, boolean fromIpc) {
        synchronized (this) {
            if (mLastProcessState != processState) {
                mLastProcessState = processState;
                // Update Dalvik state based on ActivityManager.PROCESS_STATE_* constants.
                final int DALVIK_PROCESS_STATE_JANK_PERCEPTIBLE = 0;
                final int DALVIK_PROCESS_STATE_JANK_IMPERCEPTIBLE = 1;
                int dalvikProcessState = DALVIK_PROCESS_STATE_JANK_IMPERCEPTIBLE;
                // TODO: Tune this since things like gmail sync are important background but not jank perceptible.
                if (processState <= ActivityManager.PROCESS_STATE_IMPORTANT_FOREGROUND) {
                    dalvikProcessState = DALVIK_PROCESS_STATE_JANK_PERCEPTIBLE;
                }
                VMRuntime.getRuntime().updateProcessState(dalvikProcessState);
                if (false) {
                    Slog.i(TAG, "******************* PROCESS STATE CHANGED TO: " + processState
                            + (fromIpc ? " (from ipc": ""));
                }
            }
        }
    }

    /**
     * Updates {@link #mNetworkBlockSeq}. This is used by ActivityManagerService to inform
     * the main thread that it needs to wait for the network rules to get updated before
     * launching an activity.
     */
    @Override
    public void setNetworkBlockSeq(long procStateSeq) {
        synchronized (mNetworkPolicyLock) {
            mNetworkBlockSeq = procStateSeq;
        }
    }

    @Override
    public void scheduleInstallProvider(ProviderInfo provider) {
        sendMessage(H.INSTALL_PROVIDER, provider);
    }

    @Override
    public final void updateTimePrefs(int timeFormatPreference) {
        final Boolean timeFormatPreferenceBool;
        // For convenience we are using the Intent extra values.
        if (timeFormatPreference == Intent.EXTRA_TIME_PREF_VALUE_USE_12_HOUR) {
            timeFormatPreferenceBool = Boolean.FALSE;
        } else if (timeFormatPreference == Intent.EXTRA_TIME_PREF_VALUE_USE_24_HOUR) {
            timeFormatPreferenceBool = Boolean.TRUE;
        } else {
            // timeFormatPreference == Intent.EXTRA_TIME_PREF_VALUE_USE_LOCALE_DEFAULT
            // (or unknown).
            timeFormatPreferenceBool = null;
        }
        DateFormat.set24HourTimePref(timeFormatPreferenceBool);
    }

    @Override
    public void scheduleCancelVisibleBehind(IBinder token) {
        sendMessage(H.CANCEL_VISIBLE_BEHIND, token);
    }

    @Override
    public void scheduleBackgroundVisibleBehindChanged(IBinder token, boolean visible) {
        sendMessage(H.BACKGROUND_VISIBLE_BEHIND_CHANGED, token, visible ? 1 : 0);
    }

    @Override
    public void scheduleEnterAnimationComplete(IBinder token) {
        sendMessage(H.ENTER_ANIMATION_COMPLETE, token);
    }

    @Override
    public void notifyCleartextNetwork(byte[] firstPacket) {
        if (StrictMode.vmCleartextNetworkEnabled()) {
            StrictMode.onCleartextNetworkDetected(firstPacket);
        }
    }

    @Override
    public void startBinderTracking() {
        sendMessage(H.START_BINDER_TRACKING, null);
    }

    @Override
    public void stopBinderTrackingAndDump(ParcelFileDescriptor pfd) {
        try {
            sendMessage(H.STOP_BINDER_TRACKING_AND_DUMP, pfd.dup());
        } catch (IOException e) {
        } finally {
            IoUtils.closeQuietly(pfd);
        }
    }

    @Override
    public void scheduleMultiWindowModeChanged(IBinder token, boolean isInMultiWindowMode,
            Configuration overrideConfig) throws RemoteException {
        SomeArgs args = SomeArgs.obtain();
        args.arg1 = token;
        args.arg2 = overrideConfig;
        args.argi1 = isInMultiWindowMode ? 1 : 0;
        sendMessage(H.MULTI_WINDOW_MODE_CHANGED, args);
    }

    @Override
    public void schedulePictureInPictureModeChanged(IBinder token, boolean isInPipMode,
            Configuration overrideConfig) throws RemoteException {
        SomeArgs args = SomeArgs.obtain();
        args.arg1 = token;
        args.arg2 = overrideConfig;
        args.argi1 = isInPipMode ? 1 : 0;
        sendMessage(H.PICTURE_IN_PICTURE_MODE_CHANGED, args);
    }

    @Override
    public void scheduleLocalVoiceInteractionStarted(IBinder token,
            IVoiceInteractor voiceInteractor) throws RemoteException {
        SomeArgs args = SomeArgs.obtain();
        args.arg1 = token;
        args.arg2 = voiceInteractor;
        sendMessage(H.LOCAL_VOICE_INTERACTION_STARTED, args);
    }

    @Override
    public void handleTrustStorageUpdate() {
        NetworkSecurityPolicy.getInstance().handleTrustStorageUpdate();
    }
}

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。