单线程处理模型

2024-05-06 21:18
文章标签 模型 处理 单线程

本文主要是介绍单线程处理模型，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

摘自：http://coolxing.iteye.com/blog/1284476

所谓的started service, 是我对以startService()方法启动的service的叫法. Service运行在所在进程的main thread中. 启动一个service时, 不会自动为该service创建新的thread. 这意味着开发者通常需要为service开启新的线程, 以执行耗时或者阻塞操作—否则可能导致ANR错误的发生. 既然如此, 为何不在activity中直接开启新的线程执行耗时操作或者阻塞操作呢? 原因在于一个包含正在运行的service的进程具有更安全的进程优先级--它的进程优先级至少是service process, 而activity处于后台运行时它的进程优先级为background process, 在系统内存不足时,处于后台运行的activity更有可能被系统杀死. 关于进程优先级, 在我的另一篇博文中有过介绍http://coolxing.iteye.com/blog/1279170.

如果没有调用stopService()方法或者stopSelf()方法, 就算onStartCommand()方法执行完成, 该service仍然处于active状态, 但onStartCommand()方法返回后, 系统可能处于内存不足的缘故摧毁这个service, 如果发生这种情形, 那么系统将尽快重建这个service, 而onStartCommand()方法的返回值用来定义系统该如何重建service, 返回值的可以是以下3个int值中的一个:

  • START_NOT_STICKY, 表明不要重建service. 这可以避免在非必要的情况下浪费系统的资源.
  • START_STICKY, 表明需要重建service, 并在重建service之后调用onStartCommand()方法, 传递给该方法的intent为null.
  • START_REDELIVER_INTENT, 表明需要重建service, 并在重建service之后调用onStartCommand()方法, 传递给该方法的intent为service被摧毁之前接收到的最后一个intent.     

当service第一次被启动时会调用onCreate()方法, 然后再调用onStartCommand()方法. 在该service的生命周期内,如果再次启动这个service, 就会直接调用onStartCommand()方法了.

onStartCommand(Intent intent, int flags, int startid)方法的第一个参数intent就是用于启动该service的intent, 第二个参数flags的值通常为0, 第三个参数startid标识此次启动请求, 通常用于stopSelf(int)方法.

通常情况下, started service应该使用单线程处理多个启动请求, 此时继承IntentService是一个更好的选择, 当然也可以继承Service类, 只是会导致更多的代码. 不过如果started service需要并发处理多个启动请求, 那么只能继承Service类.

继承Service--以单线程的方式处理多个启动请求

         单线程方式处理多个启动请求是大多数时候的选择, 因为该方式可以有效的处理所有请求, 却有着不需要考虑线程安全的优势. 下面的例子使用了HandlerThread和Handler类构建了单线程模型, 关于Handler, Looper, Message等线程相关的概念, 请参考我的另一篇博文http://coolxing.iteye.com/blog/1208371.

Java代码   收藏代码
  1. public class SingleService extends Service {  
  2.    private static final int NEW_INTENT_COMMING = 0;  
  3.    private Handler handler;  
  4.    
  5.    private final class WorkThreadHanlder extends Handler {  
  6.       // 使用指定Looper创建Handler  
  7.       public WorkThreadHanlder(Looper looper) {  
  8.          super(looper);  
  9.       }  
  10.    
  11.       @Override  
  12.       public void handleMessage(Message msg) {  
  13.          if (msg.what == NEW_INTENT_COMMING) {  
  14.             Log.d("SingleService", Thread.currentThread().getName());  
  15.             try {  
  16.                 Thread.sleep(5 * 1000);  
  17.             } catch (InterruptedException e) {  
  18.                 e.printStackTrace();  
  19.             }  
  20.             // arg1中存储的是onStartCommand()方法的startId参数  
  21.             stopSelf(msg.arg1);  
  22.          }  
  23.       }  
  24.    }  
  25.    
  26.    @Override  
  27.    public int onStartCommand(Intent intent, int flags, int startId) {  
  28.       Message msg = handler.obtainMessage();  
  29.       msg.arg1 = startId;  
  30.       msg.what = NEW_INTENT_COMMING;  
  31.       msg.sendToTarget();  
  32.       return START_STICKY;  
  33.    }  
  34.    
  35.    @Override  
  36.    public void onCreate() {  
  37.       super.onCreate();  
  38.       HandlerThread thread = new HandlerThread("work thread",  
  39.             Process.THREAD_PRIORITY_BACKGROUND);  
  40.       // thread启动之后才能调用getLooper()方法获取thread中的Looper对象  
  41.       thread.start();  
  42.       // 使用子线程的Looper创建handler, 该handler绑定在子线程的消息队列上  
  43.       handler = new WorkThreadHanlder(thread.getLooper());  
  44.    }  
  45.    
  46.    @Override  
  47.    public IBinder onBind(Intent intent) {  
  48.       return null;  
  49.    }  
  50. }  

继承IntentService--以单线程的方式处理多个启动请求

         从上面的例子可以看到, 在Service中构建单线程模型需要编写大量代码, 为了简化编程, android提供了IntentService类. IntentService类Service类的子类, 查看源代码可以知道IntentService只是将上例的单线程模型进行了简单的包装, 在handleMessage()方法中调用onHandleIntent()方法进行具体的请求处理, 该方法是一个抽象方法, 需要由开发者提供实现. 以下是IntentService对Service增强之处:

  • 在onCreate()方法中创建了一个子线程, 用于处理所有发送给onStartcommand()方法的intent.
  • 在onStartCommand()方法中将intent和startId存储在Message对象中, 并将该Message发送给子线程的消息队列. 因此同时存在多个启动请求时, 就会将这些请求的intent以Message的形式加入到子线程的消息队列中,然后子线程从队列中不断的取出和处理消息.
  • 由子线程的Handler对象处理消息, Handler对象的handleMessage()方法调用onHandleIntent方法后调用了stopSelf(int)方法, 因此开发者无需考虑service的退出问题.
  • onHandleIntent方法是一个抽象方法, 留待开发者提供具体实现.

因此继承IntentService可以方便的构建单线程处理启动请求的service, 开发者不需要考虑创建线程, 创建Handler, service的退出等复杂的问题, 仅需要提供一个构造函数和实现onHandleIntent方法.

使用IntentService重写上面的例子:

Java代码   收藏代码
  1. public class SingleIntentService extends IntentService {  
  2.    public SingleIntentService() {  
  3.       // 设置子线程名称  
  4.       super("work thread");  
  5.    }  
  6.    
  7.    @Override  
  8.    protected void onHandleIntent(Intent intent) {  
  9.       Log.d("SingleService", Thread.currentThread().getName());  
  10.       try {  
  11.          Thread.sleep(5 * 1000);  
  12.       } catch (InterruptedException e) {  
  13.          e.printStackTrace();  
  14.       }  
  15.    }  
  16. }  

继承Service--并发处理多个请求

         为了并发处理多个请求, 可以在考虑在onStartCommand()方法中启动新的线程处理intent. 这样, 每调用一次startService()方法就会启动一个新的线程处理请求.

Java代码   收藏代码
  1. public class MultipleService extends Service {  
  2.    @Override  
  3.    public IBinder onBind(Intent intent) {  
  4.       return null;  
  5.    }  
  6.     
  7.    @Override  
  8.    public int onStartCommand(Intent intent, int flags, final int startId) {  
  9.       new Thread() {  
  10.          public void run() {  
  11.             Log.d("SingleService", Thread.currentThread().getName());  
  12.             try {  
  13.                 Thread.sleep(5 * 1000);  
  14.             } catch (InterruptedException e) {  
  15.                 e.printStackTrace();  
  16.             }  
  17.             stopSelf(startId);  
  18.          };  
  19.       }.start();  
  20.       return super.onStartCommand(intent, flags, startId);  
  21.    }  
  22. }  
 

这篇关于单线程处理模型的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/965401。

相关文章

SpringBoot分段处理List集合多线程批量插入数据方式

SpringBoot分段处理List集合多线程批量插入数据方式

《SpringBoot分段处理List集合多线程批量插入数据方式》文章介绍如何处理大数据量List批量插入数据库的优化方案：通过拆分List并分配独立线程处理,结合Spring线程池与异步方法提升效率... 目录项目场景解决方案1.实体类2.Mapper3.spring容器注入线程池bejsan对象4.创建
阅读更多...
PHP轻松处理千万行数据的方法详解

PHP轻松处理千万行数据的方法详解

《PHP轻松处理千万行数据的方法详解》说到处理大数据集,PHP通常不是第一个想到的语言,但如果你曾经需要处理数百万行数据而不让服务器崩溃或内存耗尽,你就会知道PHP用对了工具有多强大,下面小编就... 目录问题的本质php 中的数据流处理：为什么必不可少生成器：内存高效的迭代方式流量控制：避免系统过载一次性
阅读更多...
Python实现批量CSV转Excel的高性能处理方案

Python实现批量CSV转Excel的高性能处理方案

《Python实现批量CSV转Excel的高性能处理方案》在日常办公中,我们经常需要将CSV格式的数据转换为Excel文件,本文将介绍一个基于Python的高性能解决方案,感兴趣的小伙伴可以跟随小编一... 目录一、场景需求二、技术方案三、核心代码四、批量处理方案五、性能优化六、使用示例完整代码七、小结一、
阅读更多...
Python中 try / except / else / finally 异常处理方法详解

Python中 try / except / else / finally 异常处理方法详解

《Python中try/except/else/finally异常处理方法详解》：本文主要介绍Python中try/except/else/finally异常处理方法的相关资料,涵... 目录1. 基本结构2. 各部分的作用tryexceptelsefinally3. 执行流程总结4. 常见用法（1）多个e
阅读更多...
PHP应用中处理限流和API节流的最佳实践

PHP应用中处理限流和API节流的最佳实践

《PHP应用中处理限流和API节流的最佳实践》限流和API节流对于确保Web应用程序的可靠性、安全性和可扩展性至关重要,本文将详细介绍PHP应用中处理限流和API节流的最佳实践,下面就来和小编一起学习... 目录限流的重要性在 php 中实施限流的最佳实践使用集中式存储进行状态管理（如 Redis）采用滑动
阅读更多...
MyBatis-plus处理存储json数据过程

MyBatis-plus处理存储json数据过程

《MyBatis-plus处理存储json数据过程》文章介绍MyBatis-Plus3.4.21处理对象与集合的差异：对象可用内置Handler配合autoResultMap,集合需自定义处理器继承F... 目录1、如果是对象2、如果需要转换的是List集合总结对象和集合分两种情况处理，目前我用的MP的版本
阅读更多...
Python自动化处理PDF文档的操作完整指南

Python自动化处理PDF文档的操作完整指南

《Python自动化处理PDF文档的操作完整指南》在办公自动化中,PDF文档处理是一项常见需求,本文将介绍如何使用Python实现PDF文档的自动化处理,感兴趣的小伙伴可以跟随小编一起学习一下... 目录使用pymupdf读写PDF文件基本概念安装pymupdf提取文本内容提取图像添加水印使用pdfplum
阅读更多...
C# LiteDB处理时间序列数据的高性能解决方案

C# LiteDB处理时间序列数据的高性能解决方案

《C#LiteDB处理时间序列数据的高性能解决方案》LiteDB作为.NET生态下的轻量级嵌入式NoSQL数据库,一直是时间序列处理的优选方案,本文将为大家大家简单介绍一下LiteDB处理时间序列数... 目录为什么选择LiteDB处理时间序列数据第一章：LiteDB时间序列数据模型设计1.1 核心设计原则
阅读更多...
基于Redis自动过期的流处理暂停机制

基于Redis自动过期的流处理暂停机制

《基于Redis自动过期的流处理暂停机制》基于Redis自动过期的流处理暂停机制是一种高效、可靠且易于实现的解决方案,防止延时过大的数据影响实时处理自动恢复处理,以避免积压的数据影响实时性,下面就来详... 目录核心思路代码实现1. 初始化Redis连接和键前缀2. 接收数据时检查暂停状态3. 检测到延时过
阅读更多...
Java利用@SneakyThrows注解提升异常处理效率详解

Java利用@SneakyThrows注解提升异常处理效率详解

《Java利用@SneakyThrows注解提升异常处理效率详解》这篇文章将深度剖析@SneakyThrows的原理,用法,适用场景以及隐藏的陷阱,看看它如何让Java异常处理效率飙升50%,感兴趣的... 目录前言一、检查型异常的“诅咒”：为什么Java开发者讨厌它1.1 检查型异常的痛点1.2 为什么说
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2