AI 助理
备案控制台
开发者社区 开发与运维 文章 正文

【EventBus】事件通信框架 ( 发送事件 | 判断发布线程是否是主线程 | 子线程切换主线程 | 主线程切换子线程 )（一）

2022-02-07 180
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 【EventBus】事件通信框架 ( 发送事件 | 判断发布线程是否是主线程 | 子线程切换主线程 | 主线程切换子线程 )（一）

文章目录

前言

一、根据不同的线程模式进行不同的线程切换操作

二、完整代码示例

前言

发布线程发布事件之后 , 消息中心需要转发这些事件 , 并执行相应的订阅方法 ;


在转发的过程中 , 需要针对订阅方法的 @Subscribe 注解的不同 threadMode 属性进行不同的线程模式处理 ;


假如订阅方法的线程模式属性属性是 POSTING , 直接在发布线程中调用订阅方法 ;


假如订阅方法的线程模式属性属性是 MAIN , 则需要判定发布线程是否是主线程 ;


如果发布线程是主线程 , 则直接执行订阅方法 ;

如果发布线程不是主线程 , 则需要在主线程中执行订阅方法 ;

假如订阅方法的线程模式属性是 BACKGROUND , 则需要判定发布线程是否是主线程 ;


如果发布线程是主线程 , 则切换到子线程执行订阅方法 ;

如果发布线程不是主线程 , 则直接执行订阅方法 ;


可参考 【Android 异步操作】Android 线程切换 ( 判定当前线程是否是主线程 | 子线程中执行主线程方法 | 主线程中执行子线程方法 ) 博客的部分操作 ;






一、根据不同的线程模式进行不同的线程切换操作


首先 , 获取当前线程是否是主线程 : 参考 【Android 异步操作】Android 线程切换 ( 判定当前线程是否是主线程 | 子线程中执行主线程方法 | 主线程中执行子线程方法 ) 一、判定当前线程是否是主线程 博客章节 ;


      

// 判断当前线程是否是主线程
        //      获取 mainLooper 与 myLooper 进行比较 , 如果一致 , 说明该线程是主线程
        boolean isMainThread = false;
        // 下面的情况下 , 线程是主线程
        if (Looper.getMainLooper() == Looper.myLooper()) {
            isMainThread = true;
        }


然后 , 获取订阅方法的线程模式 , 不同的线程模式进行不同的处理 ;


  

// 判断订阅方法的线程模式
        MyThreadMode threadMode = subscription.getSubscriberMethod().getThreadMode();
        switch (threadMode) {
            case POSTING:
                break;
            case MAIN:
                break;
            case MAIN_ORDERED:
                break;
            case BACKGROUND:
                break;
            case ASYNC:
                break;
        }


POSTING 线程模式下 , 不进行线程切换 , 直接调用反射方法执行订阅方法即可 ;


        

case POSTING:
                // 直接在发布线程调用订阅方法
                invokeMethod(subscription, event);
                break;


MAIN 线程模式下 , 需要判定发布线程是否是主线程 ;


如果发布线程是主线程 , 则直接执行订阅方法 ;

如果发布线程不是主线程 , 则需要在主线程中执行订阅方法 ;

为了方便 , 这里将 MAIN_ORDERED 与 MAIN 分支进行合并处理 ;


参考 【Android 异步操作】Android 线程切换 ( 判定当前线程是否是主线程 | 子线程中执行主线程方法 | 主线程中执行子线程方法 ) 二、子线程中执行主线程方法 博客章节 ;


      

case MAIN:
            case MAIN_ORDERED:
                // 如果发布线程是主线程, 直接调用
                if (isMainThread) {
                    invokeMethod(subscription, event);
                } else {
                    // 将订阅方法放到主线程执行
                    // 获取主线程 Looper , 并通过 Looper 创建 Handler
                    Handler handler = new Handler(Looper.getMainLooper());
                    // 在主线程中执行订阅方法
                    handler.post(new Runnable() {
                        @Override
                        public void run() {
                            invokeMethod(subscription, event);
                        }
                    });
                }
                break;


BACKGROUND 线程模式下 , 判定发布线程是否是主线程 ;


如果发布线程是主线程 , 则切换到子线程执行订阅方法 ;

如果发布线程不是主线程 , 则直接执行订阅方法 ;

为了方便 , 这里将 ASYNC 与 BACKGROUND 分支进行合并处理 ;


参考 【Android 异步操作】Android 线程切换 ( 判定当前线程是否是主线程 | 子线程中执行主线程方法 | 主线程中执行子线程方法 ) 三、主线程中执行子线程方法 博客章节 ;


      

case BACKGROUND:
            case ASYNC:
                // 如果是主线程 , 切换到子线程执行
                if (isMainThread) {
                    // 在线程池中执行方法
                    executorService.execute(new Runnable() {
                        @Override
                        public void run() {
                            invokeMethod(subscription, event);
                        }
                    });
                } else {
                    // 如果是子线程直接执行
                    invokeMethod(subscription, event);
                }
                break;


部分代码示例 :


 

/**
     * 调用订阅方法
     * @param subscription
     * @param event
     */
    private void postSingleSubscription(MySubscription subscription, Object event) {
        // 判断当前线程是否是主线程
        //      获取 mainLooper 与 myLooper 进行比较 , 如果一致 , 说明该线程是主线程
        boolean isMainThread = false;
        // 下面的情况下 , 线程是主线程
        if (Looper.getMainLooper() == Looper.myLooper()) {
            isMainThread = true;
        }
        // 判断订阅方法的线程模式
        MyThreadMode threadMode = subscription.getSubscriberMethod().getThreadMode();
        switch (threadMode) {
            case POSTING:
                // 直接在发布线程调用订阅方法
                invokeMethod(subscription, event);
                break;
            case MAIN:
            case MAIN_ORDERED:
                // 如果发布线程是主线程, 直接调用
                if (isMainThread) {
                    invokeMethod(subscription, event);
                } else {
                    // 将订阅方法放到主线程执行
                    // 获取主线程 Looper , 并通过 Looper 创建 Handler
                    Handler handler = new Handler(Looper.getMainLooper());
                    // 在主线程中执行订阅方法
                    handler.post(new Runnable() {
                        @Override
                        public void run() {
                            invokeMethod(subscription, event);
                        }
                    });
                }
                break;
            case BACKGROUND:
            case ASYNC:
                // 如果是主线程 , 切换到子线程执行
                if (isMainThread) {
                    // 在线程池中执行方法
                    executorService.execute(new Runnable() {
                        @Override
                        public void run() {
                            invokeMethod(subscription, event);
                        }
                    });
                } else {
                    // 如果是子线程直接执行
                    invokeMethod(subscription, event);
                }
                break;
        }
    }





文章标签：
Android开发
关键词：
事件线程
线程主线程
框架线程
线程事件
线程子线程
韩曙亮
目录
相关文章
进步`于辰
|
29天前
|
Java 调度
[Java]线程生命周期与线程通信
本文详细探讨了线程生命周期与线程通信。文章首先分析了线程的五个基本状态及其转换过程，结合JDK1.8版本的特点进行了深入讲解。接着，通过多个实例介绍了线程通信的几种实现方式，包括使用`volatile`关键字、`Object`类的`wait()`和`notify()`方法、`CountDownLatch`、`ReentrantLock`结合`Condition`以及`LockSupport`等工具。全文旨在帮助读者理解线程管理的核心概念和技术细节。
进步`于辰
38 1
[Java]线程生命周期与线程通信
众所周知
|
15天前
|
Java
JAVA多线程通信：为何wait()与notify()如此重要？
在Java多线程编程中，`wait()` 和 `notify()/notifyAll()` 方法是实现线程间通信的核心机制。它们通过基于锁的方式，使线程在条件不满足时进入休眠状态，并在条件满足时被唤醒，从而确保数据一致性和同步。相比其他通信方式，如忙等待，这些方法更高效灵活。 示例代码展示了如何在生产者-消费者模型中使用这些方法实现线程间的协调和同步。
众所周知
31 3
石小浪♪
|
1月前
SDL事件处理以及线程使用（2）
SDL库中事件处理和多线程编程的基本概念和示例代码，包括如何使用SDL事件循环来处理键盘和鼠标事件，以及如何创建和管理线程、互斥锁和条件变量。
石小浪♪
32 1
SDL事件处理以及线程使用（2）
龙大吉
|
30天前
|
安全 Java
Java多线程通信新解：本文通过生产者-消费者模型案例，深入解析wait()、notify()、notifyAll()方法的实用技巧
【10月更文挑战第20天】Java多线程通信新解：本文通过生产者-消费者模型案例，深入解析wait()、notify()、notifyAll()方法的实用技巧，包括避免在循环外调用wait()、优先使用notifyAll()、确保线程安全及处理InterruptedException等，帮助读者更好地掌握这些方法的应用。
龙大吉
19 1
众所周知
|
30天前
|
安全 Java 开发者
Java多线程中的`wait()`、`notify()`和`notifyAll()`方法，探讨了它们在实现线程间通信和同步中的关键作用
本文深入解析了Java多线程中的`wait()`、`notify()`和`notifyAll()`方法，探讨了它们在实现线程间通信和同步中的关键作用。通过示例代码展示了如何正确使用这些方法，并分享了最佳实践，帮助开发者避免常见陷阱，提高多线程程序的稳定性和效率。
众所周知
38 1
众所周知
|
30天前
|
Java
在Java多线程编程中，`wait()` 和 `notify()/notifyAll()` 方法是线程间通信的核心机制。
在Java多线程编程中，`wait()` 和 `notify()/notifyAll()` 方法是线程间通信的核心机制。它们通过基于锁的方式，使线程在条件不满足时进入休眠状态，并在条件成立时被唤醒，从而有效解决数据一致性和同步问题。本文通过对比其他通信机制，展示了 `wait()` 和 `notify()` 的优势，并通过生产者-消费者模型的示例代码，详细说明了其使用方法和重要性。
众所周知
25 1
大树营养快线
|
1月前
|
Java
在 Java 中，正确实现线程间的通信
【10月更文挑战第9天】
大树营养快线
35 1
john散漫
|
1月前
多线程通信和同步的方式有哪些？
【10月更文挑战第6天】
john散漫
104 0
1288912195458132
|
3月前
|
数据采集 Java Python
python 递归锁、信号量、事件、线程队列、进程池和线程池、回调函数、定时器
python 递归锁、信号量、事件、线程队列、进程池和线程池、回调函数、定时器
1288912195458132
31 0
热爱技术的小郑
|
3月前
【多线程面试题十一】、如何实现子线程先执行，主线程再执行？
要实现子线程先执行，主线程再执行，可以在启动子线程后立即调用其join()方法，使主线程等待子线程执行完成。
热爱技术的小郑
35 0