public void maybeBringEmbeddedTaskToForeground(int taskId) {
        if (taskId > 0) {
            // The task in TaskView should be in top to make it visible.
            // NOTE: Tried setTaskAlwaysOnTop before, the flag has some side effect to hinder
            // AccessibilityService from finding the correct window geometry: b/197247311
            mActivityManager.moveTaskToFront(taskId, /* flags= */ 0);
        }
    }

override fun setUnityVisible(visible: Boolean) {
            Log.w(TAG, "setUnityVisible:${visible}")
            val fragment = UnityPlayerFragment.Current
                if (fragment != null && fragment.isLoadUnityFinish) {
                    lastVisibleFromLauncher3 = visible
                    Log.w(TAG, "setUnityVisible:setInteractionMsg $visible")
                    if (visible) {
                        fragment.resumeUnityPlayer()
                    } else {
                        fragment.pauseUnityPlayer()
                    }
                }
        }

    }

package com.carlauncher;
import android.os.Bundle;
import com.carlauncher.IUnityBridgeCallback;

interface UnityInterface {


    oneway void registerUnityBridgeCallback(IUnityBridgeCallback callback);
    oneway void unregisterUnityBridgeCallback(IUnityBridgeCallback callback);

    /**
     * 通知Unity 交互信息传递
     * 交互信息传输专用，除Adapter都放这里  EX：车衣按钮被点击 | 天气信息传递（bx1e） | 其他
     *
     * @param msgType 消息类型
     * @param msgData 消息
     */
    oneway void setInteractionMsg(int msgType, in Bundle bundle);


   /**
    * 设置Unity是否处于显示状态
    */
    oneway void setUnityVisible(boolean visible);

}

public class AutoPullExecutor<K, E> extends Thread {
    private static final String TAG = "AutoPullExecutor";
    private final FilterCache<K, E> mCache;
    private final List<FilterCacheHelper.OnPullCacheCallback<K, E>> mCallbacks;
    private boolean mIsRunning = false;

    public AutoPullExecutor(FilterCache<K, E> cache) {
        mCache = cache;
        mCallbacks = new ArrayList<>();
    }

    @Override
    public void run() {
        Log.d(TAG, "AutoPullExecutor is start");
        mIsRunning = true;
        while (mIsRunning) {
            FilterCache.Node<K, E> node = mCache.poll();

            if (node == null) {
                continue;
            }


            autoPullCallback(node);
        }
    }

    private void autoPullCallback(FilterCache.Node<K, E> node) {
        for (FilterCacheHelper.OnPullCacheCallback<K, E> callback : mCallbacks) {
            callback.onCache(node.key, node.element);
        }
    }

    void addPullCallback(FilterCacheHelper.OnPullCacheCallback<K, E> callback) {
        mCallbacks.add(callback);
    }

    boolean isRunning() {
        return mIsRunning;
    }

    void exit() {
        mIsRunning = false;
        interrupt();
        clear();
    }

    void clear() {
        mCallbacks.clear();
    }
}