Android:线程间通讯、Handler、Looper、IntentService、自定义消息队列

简介:

Android:线程间通讯、Handler、Looper、IntentService


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
public  class  MainActivity  extends  Activity  implements  OnClickListener
{
     private  Handler mHandler;
     private  TextView textView;
        
     /**
      * 1.继承ItentService类的public myservice()构造方法必须存在 
      * 2.如果已经startservice,再次start的话,会调用onbindservice
      * 3.线程深入封装:HandlerThread和IntentService
      * 4.IntentService:
      *   class MyService extends IntentService
      *   {
      *      public MyService()
      *      {
      *          super("xxx");
      *      }
      *      onHandleMessage()
      *      {
      *          // 在"xxx"线程处理耗时操作
      *      }
      *      onBind()
      *   }      
      */
        
     @Override
     protected  void  onCreate(Bundle savedInstanceState)
     {
         super .onCreate(savedInstanceState);
         setContentView(R.layout.activity_main);
            
         findViewById(R.id.button1).setOnClickListener( this );
         findViewById(R.id.button2).setOnClickListener( this );
         findViewById(R.id.button3).setOnClickListener( this );
         textView = (TextView) findViewById(R.id.textView1);
     }
        
     @Override
     public  boolean  onCreateOptionsMenu(Menu menu)
     {
         getMenuInflater().inflate(R.menu.activity_main, menu);
         return  true ;
     }
     @Override
     public  void  onClick(View v)
     {
         switch  (v.getId())
         {
         case  R.id.button1:
             btn1Click();
             break ;
         case  R.id.button2:
             btn2Click();
             break ;
         case  R.id.button3:
             btn3Click();
             break ;
            
         default :
             break ;
         }
     }
     private  void  btn3Click()
     {
         new  Thread( "子线程2" )
         {
             @Override
             public  void  run()
             {
                 Message msg =  new  Message();
                 msg.obj =  30 ;
                 mHandler.sendMessage(msg);
             }
         }.start();
     }
     private  void  btn2Click() //将main线程消息发送给子线程
     {
            
         Message msg =  new  Message();
         msg.arg2 =  20 ;
         mHandler.sendMessage(msg);
     }
     private  void  btn1Click() //启动自定义消息队列
     {
         try
         {
             Thread.sleep( 5000 );
         }
         catch  (InterruptedException e)
         {
             e.printStackTrace();
         }
         new  Thread( "子线程" )
         {
             @Override
             public  void  run()
             {
                 Looper.prepare(); //创建Looper和MessageQueue两个对象
                 mHandler =  new  Handler() //由Looper决定哪个线程来执行Handler
                 {
                     public  void  handleMessage(android.os.Message msg)
                     {
                         String threadname = Thread.currentThread().getName();
                         Log.e( "handler" "threadname:"  + threadname +  " msg_1:"  + msg.arg1 +  " msg_main:"  + msg.arg2 +  " msg_2:"  + msg.obj); //可以接收到消息,自己给自己发送消息
                     };
                 };
                    
                 Message msg =  new  Message();
                 msg.arg1 =  10 ;
                 mHandler.sendMessage(msg);
                    
//                mHandler.sendEmptyMessage(1);
                    
                 Looper.loop(); //在该线程中运行消息
             }
         }.start();
     }
        
}




注:

1.结束子线程的方法:设置一个flag标记进行判断

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
     private  void  saveCityInfo( final  HttpHelperResponse response)
     {
         new  Thread( new  Runnable()
         {
             @Override
             public  void  run()
             {
                 while  (!isThreadOver)
                 {
                     Looper.prepare();
                     CityInfoList cityInfo = HBJsonUtils.parseAllCityInfoJson(response.getMsgStr()); // 解析
                     // 将下载结果写入缓存
                     mDBHelper.addToCache(cityInfo, mCityId);
                     
                     // 释放
                     recycleCityInfoList(cityInfo);
                     
                     handler.sendEmptyMessage(MSG_SAVE_CITYINFO);
                     Looper.loop();
                 }
             }
         }).start();
     }




本文转自 glblong 51CTO博客,原文链接:http://blog.51cto.com/glblong/1210685,如需转载请自行联系原作者
目录
打赏
0
0
0
0
234
分享
相关文章
Android消息处理机制(Handler+Looper+Message+MessageQueue)
Android消息处理机制(Handler+Looper+Message+MessageQueue)
64 2
Android面试高频知识点(2) 详解Android消息处理机制(Handler)
Android面试高频知识点(2) 详解Android消息处理机制(Handler)
Android面试高频知识点(2) 详解Android消息处理机制(Handler)
Android面试高频知识点(2) 详解Android消息处理机制(Handler)
76 1
Android消息处理机制(Handler+Looper+Message+MessageQueue)
Android消息处理机制(Handler+Looper+Message+MessageQueue)
113 2
Android面试高频知识点(2) 详解Android消息处理机制(Handler)
Android 消息处理机制估计都被写烂了,但是依然还是要写一下,因为Android应用程序是通过消息来驱动的,Android某种意义上也可以说成是一个以消息驱动的系统,UI、事件、生命周期都和消息处理机制息息相关,并且消息处理机制在整个Android知识体系中也是尤其重要,在太多的源码分析的文章讲得比较繁琐,很多人对整个消息处理机制依然是懵懵懂懂,这篇文章通过一些问答的模式结合Android主线程(UI线程)的工作原理来讲解,源码注释很全,还有结合流程图,如果你对Android 消息处理机制还不是很理解,我相信只要你静下心来耐心的看,肯定会有不少的收获的。
257 3
Android面试高频知识点(2) 详解Android消息处理机制(Handler)
Java多线程通讯
这些机制都是多线程通信的关键,使用它们可以在Java中实现高效、安全的线程协作。在实现多线程通信时,需注意死锁、饥饿、竞态条件等多线程问题。确保对多线程的理解深入和正确的设计模式应用将会是编写稳健多线程程序的基础。
31 0
消息队列 MQ操作报错合集之出现"Connection reset by peer"的错误,该如何处理
消息队列(MQ)是一种用于异步通信和解耦的应用程序间消息传递的服务,广泛应用于分布式系统中。针对不同的MQ产品,如阿里云的RocketMQ、RabbitMQ等,它们在实现上述场景时可能会有不同的特性和优势,比如RocketMQ强调高吞吐量、低延迟和高可用性,适合大规模分布式系统;而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集,这些场景涵盖了多种行业和业务需求。
消息队列 MQ使用问题之在使用C++客户端和GBase的ESQL进行编译时出现core dump,该怎么办
消息队列(MQ)是一种用于异步通信和解耦的应用程序间消息传递的服务,广泛应用于分布式系统中。针对不同的MQ产品,如阿里云的RocketMQ、RabbitMQ等,它们在实现上述场景时可能会有不同的特性和优势,比如RocketMQ强调高吞吐量、低延迟和高可用性,适合大规模分布式系统;而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集,这些场景涵盖了多种行业和业务需求。
MQ 消息队列核心原理,12 条最全面总结!
本文总结了消息队列的12个核心原理,涵盖消息顺序性、ACK机制、持久化及高可用性等内容。关注【mikechen的互联网架构】,10年+BAT架构经验倾囊相授。
手撸MQ消息队列——循环数组
队列是一种常用的数据结构,类似于栈,但采用先进先出(FIFO)的原则。生活中常见的排队场景就是队列的应用实例。在数据结构中,队列通常用数组实现,包括入队(队尾插入元素)和出队(队头移除元素)两种基本操作。本文介绍了如何用数组实现队列,包括定义数组长度、维护队头和队尾下标(front 和 tail),并通过取模运算解决下标越界问题。此外,还讨论了队列的空与满状态判断,以及并发和等待机制的实现。通过示例代码展示了队列的基本操作及优化方法,确保多线程环境下的正确性和高效性。
73 0
手撸MQ消息队列——循环数组