Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 6578df0b authored by Peter Kalauskas's avatar Peter Kalauskas
Browse files

Convert SysUIConcurrencyModule to kotlin 

Bug: 331536621
Flag: NONE Java-to-Kotlin conversion has no effect on runtime behavior
Test: SystemUITests
Change-Id: Ie2069aa21b51d8099f92e536d4a56c145e09c79b
parent daed658a

packages/SystemUI/src/com/android/systemui/util/concurrency/SysUIConcurrencyModule.java

deleted100644 → 0
+0 −231
Original line number Diff line number Diff line 
/*

 * Copyright (C) 2019 The Android Open Source Project

 *

 * Licensed under the Apache License, Version 2.0 (the "License");

 * you may not use this file except in compliance with the License.

 * You may obtain a copy of the License at

 *

 *      http://www.apache.org/licenses/LICENSE-2.0

 *

 * Unless required by applicable law or agreed to in writing, software

 * distributed under the License is distributed on an "AS IS" BASIS,

 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

 * See the License for the specific language governing permissions and

 * limitations under the License.

 */



package com.android.systemui.util.concurrency;



import static com.android.systemui.Dependency.TIME_TICK_HANDLER_NAME;



import android.os.Handler;

import android.os.HandlerThread;

import android.os.Looper;

import android.os.Process;



import com.android.systemui.Flags;

import com.android.systemui.dagger.SysUISingleton;

import com.android.systemui.dagger.qualifiers.Background;

import com.android.systemui.dagger.qualifiers.BroadcastRunning;

import com.android.systemui.dagger.qualifiers.LongRunning;

import com.android.systemui.dagger.qualifiers.Main;

import com.android.systemui.dagger.qualifiers.NotifInflation;



import dagger.Module;

import dagger.Provides;



import java.util.concurrent.Executor;



import javax.inject.Named;



/**

 * Dagger Module for classes found within the concurrent package.

 */

@Module

public abstract class SysUIConcurrencyModule {



    // Slow BG executor can potentially affect UI if UI is waiting for an updated state from this

    // thread

    private static final Long BG_SLOW_DISPATCH_THRESHOLD = 1000L;

    private static final Long BG_SLOW_DELIVERY_THRESHOLD = 1000L;

    private static final Long LONG_SLOW_DISPATCH_THRESHOLD = 2500L;

    private static final Long LONG_SLOW_DELIVERY_THRESHOLD = 2500L;

    private static final Long BROADCAST_SLOW_DISPATCH_THRESHOLD = 1000L;

    private static final Long BROADCAST_SLOW_DELIVERY_THRESHOLD = 1000L;

    private static final Long NOTIFICATION_INFLATION_SLOW_DISPATCH_THRESHOLD = 1000L;

    private static final Long NOTIFICATION_INFLATION_SLOW_DELIVERY_THRESHOLD = 1000L;



    /** Background Looper */

    @Provides

    @SysUISingleton

    @Background

    public static Looper provideBgLooper() {

        HandlerThread thread = new HandlerThread("SysUiBg",

                Process.THREAD_PRIORITY_BACKGROUND);

        thread.start();

        thread.getLooper().setSlowLogThresholdMs(BG_SLOW_DISPATCH_THRESHOLD,

                BG_SLOW_DELIVERY_THRESHOLD);

        return thread.getLooper();

    }



    /** BroadcastRunning Looper (for sending and receiving broadcasts) */

    @Provides

    @SysUISingleton

    @BroadcastRunning

    public static Looper provideBroadcastRunningLooper() {

        HandlerThread thread = new HandlerThread("BroadcastRunning",

                Process.THREAD_PRIORITY_BACKGROUND);

        thread.start();

        thread.getLooper().setSlowLogThresholdMs(BROADCAST_SLOW_DISPATCH_THRESHOLD,

                BROADCAST_SLOW_DELIVERY_THRESHOLD);

        return thread.getLooper();

    }



    /** Long running tasks Looper */

    @Provides

    @SysUISingleton

    @LongRunning

    public static Looper provideLongRunningLooper() {

        HandlerThread thread = new HandlerThread("SysUiLng",

                Process.THREAD_PRIORITY_BACKGROUND);

        thread.start();

        thread.getLooper().setSlowLogThresholdMs(LONG_SLOW_DISPATCH_THRESHOLD,

                LONG_SLOW_DELIVERY_THRESHOLD);

        return thread.getLooper();

    }



    /** Notification inflation Looper */

    @Provides

    @SysUISingleton

    @NotifInflation

    public static Looper provideNotifInflationLooper(@Background Looper bgLooper) {

        if (!Flags.dedicatedNotifInflationThread()) {

            return bgLooper;

        }



        final HandlerThread thread = new HandlerThread("NotifInflation",

                Process.THREAD_PRIORITY_BACKGROUND);

        thread.start();

        final Looper looper = thread.getLooper();

        looper.setSlowLogThresholdMs(NOTIFICATION_INFLATION_SLOW_DISPATCH_THRESHOLD,

                NOTIFICATION_INFLATION_SLOW_DELIVERY_THRESHOLD);

        return looper;

    }



    /**

     * Background Handler.

     *

     * Prefer the Background Executor when possible.

     */

    @Provides

    @Background

    public static Handler provideBgHandler(@Background Looper bgLooper) {

        return new Handler(bgLooper);

    }



    /**

     * Provide a BroadcastRunning Executor (for sending and receiving broadcasts).

     */

    @Provides

    @SysUISingleton

    @BroadcastRunning

    public static Executor provideBroadcastRunningExecutor(@BroadcastRunning Looper looper) {

        return new ExecutorImpl(looper);

    }



    /**

     * Provide a Long running Executor.

     */

    @Provides

    @SysUISingleton

    @LongRunning

    public static Executor provideLongRunningExecutor(@LongRunning Looper looper) {

        return new ExecutorImpl(looper);

    }



    /**

     * Provide a Long running Executor.

     */

    @Provides

    @SysUISingleton

    @LongRunning

    public static DelayableExecutor provideLongRunningDelayableExecutor(

            @LongRunning Looper looper) {

        return new ExecutorImpl(looper);

    }



    /**

     * Provide a Background-Thread Executor.

     */

    @Provides

    @SysUISingleton

    @Background

    public static Executor provideBackgroundExecutor(@Background Looper looper) {

        return new ExecutorImpl(looper);

    }



    /**

     * Provide a Background-Thread Executor.

     */

    @Provides

    @SysUISingleton

    @Background

    public static DelayableExecutor provideBackgroundDelayableExecutor(@Background Looper looper) {

        return new ExecutorImpl(looper);

    }



    /**

     * Provide a Background-Thread Executor.

     */

    @Provides

    @SysUISingleton

    @Background

    public static RepeatableExecutor provideBackgroundRepeatableExecutor(

            @Background DelayableExecutor exec) {

        return new RepeatableExecutorImpl(exec);

    }



    /**

     * Provide a Main-Thread Executor.

     */

    @Provides

    @SysUISingleton

    @Main

    public static RepeatableExecutor provideMainRepeatableExecutor(@Main DelayableExecutor exec) {

        return new RepeatableExecutorImpl(exec);

    }



    /** */

    @Provides

    @Main

    public static MessageRouter providesMainMessageRouter(

            @Main DelayableExecutor executor) {

        return new MessageRouterImpl(executor);

    }



    /** */

    @Provides

    @Background

    public static MessageRouter providesBackgroundMessageRouter(

            @Background DelayableExecutor executor) {

        return new MessageRouterImpl(executor);

    }



    /** */

    @Provides

    @SysUISingleton

    @Named(TIME_TICK_HANDLER_NAME)

    public static Handler provideTimeTickHandler() {

        HandlerThread thread = new HandlerThread("TimeTick");

        thread.start();

        return new Handler(thread.getLooper());

    }



    /** */

    @Provides

    @SysUISingleton

    @NotifInflation

    public static Executor provideNotifInflationExecutor(@NotifInflation Looper looper) {

        return new ExecutorImpl(looper);

    }

}

packages/SystemUI/src/com/android/systemui/util/concurrency/SysUIConcurrencyModule.kt

0 → 100644
+194 −0
Original line number Diff line number Diff line 
/*

 * Copyright (C) 2024 The Android Open Source Project

 *

 * Licensed under the Apache License, Version 2.0 (the "License");

 * you may not use this file except in compliance with the License.

 * You may obtain a copy of the License at

 *

 *      http://www.apache.org/licenses/LICENSE-2.0

 *

 * Unless required by applicable law or agreed to in writing, software

 * distributed under the License is distributed on an "AS IS" BASIS,

 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

 * See the License for the specific language governing permissions and

 * limitations under the License.

 */

package com.android.systemui.util.concurrency



import android.os.Handler

import android.os.HandlerThread

import android.os.Looper

import android.os.Process

import com.android.systemui.Dependency

import com.android.systemui.Flags

import com.android.systemui.dagger.SysUISingleton

import com.android.systemui.dagger.qualifiers.Background

import com.android.systemui.dagger.qualifiers.BroadcastRunning

import com.android.systemui.dagger.qualifiers.LongRunning

import com.android.systemui.dagger.qualifiers.Main

import com.android.systemui.dagger.qualifiers.NotifInflation

import dagger.Module

import dagger.Provides

import java.util.concurrent.Executor

import javax.inject.Named



/** Dagger Module for classes found within the concurrent package. */

@Module

object SysUIConcurrencyModule {

    // Slow BG executor can potentially affect UI if UI is waiting for an updated state from this

    // thread

    private const val BG_SLOW_DISPATCH_THRESHOLD = 1000L

    private const val BG_SLOW_DELIVERY_THRESHOLD = 1000L

    private const val LONG_SLOW_DISPATCH_THRESHOLD = 2500L

    private const val LONG_SLOW_DELIVERY_THRESHOLD = 2500L

    private const val BROADCAST_SLOW_DISPATCH_THRESHOLD = 1000L

    private const val BROADCAST_SLOW_DELIVERY_THRESHOLD = 1000L

    private const val NOTIFICATION_INFLATION_SLOW_DISPATCH_THRESHOLD = 1000L

    private const val NOTIFICATION_INFLATION_SLOW_DELIVERY_THRESHOLD = 1000L



    /** Background Looper */

    @Provides

    @SysUISingleton

    @Background

    fun provideBgLooper(): Looper {

        val thread = HandlerThread("SysUiBg", Process.THREAD_PRIORITY_BACKGROUND)

        thread.start()

        thread

            .getLooper()

            .setSlowLogThresholdMs(BG_SLOW_DISPATCH_THRESHOLD, BG_SLOW_DELIVERY_THRESHOLD)

        return thread.getLooper()

    }



    /** BroadcastRunning Looper (for sending and receiving broadcasts) */

    @Provides

    @SysUISingleton

    @BroadcastRunning

    fun provideBroadcastRunningLooper(): Looper {

        val thread = HandlerThread("BroadcastRunning", Process.THREAD_PRIORITY_BACKGROUND)

        thread.start()

        thread

            .getLooper()

            .setSlowLogThresholdMs(

                BROADCAST_SLOW_DISPATCH_THRESHOLD,

                BROADCAST_SLOW_DELIVERY_THRESHOLD

            )

        return thread.getLooper()

    }



    /** Long running tasks Looper */

    @Provides

    @SysUISingleton

    @LongRunning

    fun provideLongRunningLooper(): Looper {

        val thread = HandlerThread("SysUiLng", Process.THREAD_PRIORITY_BACKGROUND)

        thread.start()

        thread

            .getLooper()

            .setSlowLogThresholdMs(LONG_SLOW_DISPATCH_THRESHOLD, LONG_SLOW_DELIVERY_THRESHOLD)

        return thread.getLooper()

    }



    /** Notification inflation Looper */

    @Provides

    @SysUISingleton

    @NotifInflation

    fun provideNotifInflationLooper(@Background bgLooper: Looper): Looper {

        if (!Flags.dedicatedNotifInflationThread()) {

            return bgLooper

        }

        val thread = HandlerThread("NotifInflation", Process.THREAD_PRIORITY_BACKGROUND)

        thread.start()

        val looper = thread.getLooper()

        looper.setSlowLogThresholdMs(

            NOTIFICATION_INFLATION_SLOW_DISPATCH_THRESHOLD,

            NOTIFICATION_INFLATION_SLOW_DELIVERY_THRESHOLD

        )

        return looper

    }



    /**

     * Background Handler.

     *

     * Prefer the Background Executor when possible.

     */

    @Provides

    @Background

    fun provideBgHandler(@Background bgLooper: Looper): Handler = Handler(bgLooper)



    /** Provide a BroadcastRunning Executor (for sending and receiving broadcasts). */

    @Provides

    @SysUISingleton

    @BroadcastRunning

    fun provideBroadcastRunningExecutor(@BroadcastRunning looper: Looper): Executor =

        ExecutorImpl(looper)



    /** Provide a Long running Executor. */

    @Provides

    @SysUISingleton

    @LongRunning

    fun provideLongRunningExecutor(@LongRunning looper: Looper): Executor = ExecutorImpl(looper)



    /** Provide a Long running Executor. */

    @Provides

    @SysUISingleton

    @LongRunning

    fun provideLongRunningDelayableExecutor(@LongRunning looper: Looper): DelayableExecutor =

        ExecutorImpl(looper)



    /** Provide a Background-Thread Executor. */

    @Provides

    @SysUISingleton

    @Background

    fun provideBackgroundExecutor(@Background looper: Looper): Executor = ExecutorImpl(looper)



    /** Provide a Background-Thread Executor. */

    @Provides

    @SysUISingleton

    @Background

    fun provideBackgroundDelayableExecutor(@Background looper: Looper): DelayableExecutor =

        ExecutorImpl(looper)



    /** Provide a Background-Thread Executor. */

    @Provides

    @SysUISingleton

    @Background

    fun provideBackgroundRepeatableExecutor(

        @Background exec: DelayableExecutor

    ): RepeatableExecutor = RepeatableExecutorImpl(exec)



    /** Provide a Main-Thread Executor. */

    @Provides

    @SysUISingleton

    @Main

    fun provideMainRepeatableExecutor(@Main exec: DelayableExecutor): RepeatableExecutor =

        RepeatableExecutorImpl(exec)



    /**  */

    @Provides

    @Main

    fun providesMainMessageRouter(@Main executor: DelayableExecutor): MessageRouter =

        MessageRouterImpl(executor)



    /**  */

    @Provides

    @Background

    fun providesBackgroundMessageRouter(@Background executor: DelayableExecutor): MessageRouter =

        MessageRouterImpl(executor)



    /**  */

    @Provides

    @SysUISingleton

    @Named(Dependency.TIME_TICK_HANDLER_NAME)

    fun provideTimeTickHandler(): Handler {

        val thread = HandlerThread("TimeTick")

        thread.start()

        return Handler(thread.getLooper())

    }



    /**  */

    @Provides

    @SysUISingleton

    @NotifInflation

    fun provideNotifInflationExecutor(@NotifInflation looper: Looper): Executor =

        ExecutorImpl(looper)

}