Android 多線程處理之多線程用法大集合

C++多線程socket的服務(wù)器

• 類型：服務(wù)器區(qū)大�。�21KB語(yǔ)言：中文 評(píng)分：6.6
• 標(biāo)簽：

立即下載

handler.post(r)其實(shí)這樣并不會(huì)新起線程，只是執(zhí)行的runnable里的run()方法，卻沒(méi)有執(zhí)行start()方法，所以runnable走的還是UI線程。

1.如果像這樣，是可以操作ui,但是run還是走在主線程，見(jiàn)打印出來(lái)的Log線程名字是main，說(shuō)明是主線程。

這就是為什么可以直接在run方法里操作ui,因?yàn)樗�本質(zhì)還是ui線程

handler.post(new Runnable(){

　　public void run(){

　　Log.e("當(dāng)前線程：",Thread.currrentThread.getName());//這里打印de結(jié)果會(huì)是main

　　setTitle("哈哈");

      }

});

2.通過(guò)HandlerThread獲取到looper卻是可以新起線程，但是在這里的run方法里操作ui是不可能的，但是這顯然有個(gè)缺點(diǎn)，如果你執(zhí)行多次post(r)方法其實(shí)走的還是HandlerThread線程。假如你執(zhí)行5次，n次，其實(shí)還是一次并且它們是串行的。假如下載5張圖片，你會(huì)看到圖片是下完第一張，才會(huì)去下第二張。

實(shí)踐證明，只有是擁有主線程looper的handler才可以操作ui,而在主線程操作ui可以在handler的handlerMessage()方法中操作Ui,也可以在handler的post(r)的run方法里操作Ui.

HandlerThread ht = new HandlerThread("handler thread");

ht.start();

handler = new Handler(ht.getLooper());

handler.post(new Runnable(){//這里run()方法其實(shí)還是在等ht.start()調(diào)用

　　public void run(){

　　Log.e("當(dāng)前線程：",Thread.currrentThread.getName());//這里打印的會(huì)是handler thread

　　setTitle("哈哈");//這樣必定報(bào)錯(cuò)

　　//android.view.ViewRoot$CalledFromWrongThreadException: Only the original thread that created a view hierarchy can touch its views.

      }

});

這樣該怎么辦呢，呵呵，可以無(wú)參構(gòu)建一個(gè)handler。用這個(gè)handler來(lái)發(fā)送消息和處理消息，用上面的handler來(lái)開(kāi)啟新線程。

mainHandler = new Handler(){

　　protecket void handlerMessage(Message msg){

　　　　setTitle("哈哈");//這樣就不會(huì)報(bào)錯(cuò)啦

　　}

}

handler.post(new Runnable(){//這里run()方法其實(shí)還是在等ht.start()調(diào)用

　　public void run(){

　　Log.e("當(dāng)前線程：",Thread.currrentThread.getName());//這里打印的會(huì)是handler thread

　　mainHandler.sendEmpetMessage();//用mainHandler來(lái)發(fā)送消息

　　//setTitle("哈哈");//這樣必定報(bào)錯(cuò)

　　//android.view.ViewRoot$CalledFromWrongThreadException: Only the original thread that created a view hierarchy can touch its views.

      }

});

打印Log:

3.其實(shí)第2個(gè)方法顯得麻煩而且低效，用了2個(gè)handler，一個(gè)用來(lái)發(fā)起線程，一個(gè)用于處理消息。發(fā)起線程的handler必須擁有l(wèi)ooper，所以還要實(shí)例化一個(gè)HanderThread；而處理消息的handler則不需要looper，因?yàn)樗�默認(rèn)擁有主線程的looper，所以可以在這個(gè)handler處理ui。

其實(shí)可以只需要實(shí)例化一個(gè)handler，在主線程里構(gòu)建一個(gè)無(wú)參的handler，然后由它發(fā)送和處理消息。而創(chuàng)建線程的任務(wù)就不用handler了，直接用new Thread(r).start();然后在r的run()方法里面處理邏輯事務(wù)。

用這樣的模式下載5張圖片，你就可能不會(huì)看到圖片一張挨著一張展示出來(lái)，可能第2張先出來(lái)，也可能同時(shí)出來(lái)3張，5條線程很隨機(jī)的。

private void loadImagesByThread(final String url,final int id){//通過(guò)Thread來(lái)new 出多個(gè)線程
       
        new Thread(new Runnable(){

            @Override
            public void run() {
                // TODO Auto-generated method stub
                Log.e("當(dāng)前線程：", ""+Thread.currentThread().getName());
                Drawable drawable = null;
                try {
                    drawable = Drawable.createFromStream(new URL(url).openStream(), "image.gif");
                } catch (MalformedURLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                } catch (IOException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                Message msg = mainHandler.obtainMessage();
                msg.what = 2012;
                msg.arg1 = id;
                msg.obj = drawable;
                msg.sendToTarget();
               
            }
           
        }).start();
    }

打印Log:

4.AsyncTask

用異步任務(wù)架構(gòu)多任務(wù)模型其實(shí)也不是很健壯，得創(chuàng)建多個(gè)AsyncTask實(shí)例。一個(gè)AsyncTask僅執(zhí)行一次，不能重復(fù)執(zhí)行，快餐類的線程，一次用完。

實(shí)現(xiàn)AsyncTask子類，最重要的兩個(gè)方法，一個(gè)是doInBackground(params);一個(gè)是onPostExecute(result)。在doInBackground()方法里處理耗時(shí)事務(wù)，并把結(jié)果返回，返回的值將在onPostExecute方法作為參數(shù)，然后就可以在onPostExecute()把結(jié)果展示在ui上面了。

步驟：

①實(shí)例化AsyncTask：

實(shí)例化AsyncTask然后通過(guò)task.exec(pamas);傳進(jìn)去參數(shù)，這個(gè)參數(shù)列表是動(dòng)態(tài)的，可以是一個(gè)也可以使多個(gè)，長(zhǎng)度可變。

　　AsyncTask,第一個(gè)參數(shù)會(huì)傳進(jìn)去這個(gè)方法doInBackground(params)，第二個(gè)參數(shù)是數(shù)據(jù)更新的值，第三個(gè)是處理事務(wù)返回的結(jié)果。

②onPreExecute方法：

這個(gè)方法沒(méi)有參數(shù)，也沒(méi)有返回值，可以在這個(gè)方法里，做一些提醒。比如show一個(gè)Dialog，或者彈個(gè)Toast告訴用戶開(kāi)始下載啦。

③doInBackground(params)方法:

進(jìn)入AsyncTask內(nèi)部結(jié)構(gòu)，首先將執(zhí)行reslut doInBackground(params)方法，這個(gè)方法將處理耗時(shí)事務(wù)，exec()的參數(shù)將會(huì)傳進(jìn)這個(gè)方法做參數(shù)，而返回值將會(huì)作為onPostExecute()的參數(shù)。如果要更新進(jìn)度的話，需執(zhí)行publicProgress()方法。

④onProgressUpdate(values)方法：

這個(gè)方法的參數(shù)必須在doInBackground()方法里執(zhí)行publicProgress()方法，這個(gè)方法將會(huì)把參數(shù)傳遞進(jìn)onProgressUpdate()方法里，然后可以在這個(gè)方法做一些ui上的更新展示，比如進(jìn)度條的值就可以通過(guò)這個(gè)values值動(dòng)態(tài)改變。

⑤onPostExecute(result)方法：

這里就是事務(wù)處理完畢的走的方法，doInBackground方法執(zhí)行的結(jié)果將傳到這里，如果這個(gè)方法返回了數(shù)據(jù)。在這個(gè)方法里可以處理Ui，可以把處理完的數(shù)據(jù)展示在ui上。比如圖片啊，文字啊，一切你想要的結(jié)果。

private void loadImageByAsyncTask(final String url,final int id){//構(gòu)建異步任務(wù)，這樣就不用handler來(lái)處理消息了
        DownloadTask task = new DownloadTask();
        task.execute(""+id,url);//AsyncTask不可重復(fù)執(zhí)行
    }
   
    class DownloadTask extends AsyncTask{

        int id;
        @Override
        protected Drawable doInBackground(String... params) {//params保存url和控件id兩個(gè)數(shù)據(jù)
            // TODO Auto-generated method stub
            Log.e("當(dāng)前線程：", ""+Thread.currentThread().getName());
            Drawable drawable = null;
            this.id = Integer.parseInt(params[0]);
            try {
                drawable = Drawable.createFromStream(new URL(params[1]).openStream(), "image.gif");
            } catch (MalformedURLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
           
            return drawable;
        }

        @Override
        protected void onPostExecute(Drawable result) {
            // TODO Auto-generated method stub
            super.onPostExecute(result);
            ((ImageView)MainActivity.this.findViewById(id)).setImageDrawable(result);
        }

        @Override
        protected void onPreExecute() {
            // TODO Auto-generated method stub
            super.onPreExecute();
        }

        @Override
        protected void onProgressUpdate(Integer... values) {
            // TODO Auto-generated method stub
            super.onProgressUpdate(values);
        }

       
    }

這里打印的log

5.ExecutorServie線程池

通過(guò)Executors的靜態(tài)方法來(lái)創(chuàng)建，一般有三種：

1.單線程 ：Executors.newSingleThreadExecutor();

2.固定數(shù)量線程 ：Executors.newFixedThreadPool();

3.動(dòng)態(tài)線程 ：Executors.newCachedThreadPool();

這里我們用固定5個(gè)線程來(lái)應(yīng)用，使用方法是創(chuàng)建ExecutorService對(duì)象，然后執(zhí)行submit(r)可以發(fā)起一個(gè)Runnable對(duì)象。用線程池來(lái)管理的好處是，可以保證系統(tǒng)穩(wěn)定運(yùn)行，適用與有大量線程，高工作量的情景下使用，假如要展示1000張圖片如果創(chuàng)建1000個(gè)線程去加載，保證系統(tǒng)會(huì)死掉。用線程池就可以避免這個(gè)問(wèn)題，可以用5個(gè)線程輪流執(zhí)行，5個(gè)一組，執(zhí)行完的線程不直接回收而是等待下次執(zhí)行，這樣對(duì)系統(tǒng)的開(kāi)銷就可以減小不少。

private void loadImagesByExecutors(final String url,final int id){
        service.submit(new Runnable(){
           
            @Override
            public void run() {
                // TODO Auto-generated method stub
                Log.e("當(dāng)前線程：", ""+Thread.currentThread().getName());
               
                try {
                    final Drawable drawable  = Drawable.createFromStream(new URL(url).openStream(), "image.gif");
                    mainHandler.post(new Runnable(){

                        @Override
                        public void run() {//這將在主線程運(yùn)行
                            // TODO Auto-generated method stub
                            ((ImageView)MainActivity.this.findViewById(id)).setImageDrawable(drawable);
                        }
                    });
                   
                } catch (MalformedURLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                } catch (IOException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
               
            }
           
        });
       
    }

Log:

其實(shí)可能沒(méi)有說(shuō)清楚，第一種不算多線程。

1.loadImagesByHandler()是通過(guò)Handler.post()方法，構(gòu)建兩個(gè)Handler進(jìn)行通信。

2.loadImagesByThread()，這個(gè)是直接new Thread()發(fā)起線程，在主線程的handler處理消息

3.loadImageByAsyncTask(),這個(gè)用的是異步任務(wù)，所有實(shí)現(xiàn)在它的內(nèi)部結(jié)構(gòu)里，可以在里頭操作Ui.

4.loadImagesByExecutors()用的是線程池，使得線程可控，保證穩(wěn)定運(yùn)行。

其實(shí)常用的就是后三種，第二個(gè)用法靈活，簡(jiǎn)單，但不適宜大數(shù)量任務(wù)；第三個(gè)一般適用于單個(gè)任務(wù)，一次性任務(wù)；第四個(gè)一般用于大數(shù)量，高密度執(zhí)行的使用情景，比如批量加載圖片，批量下載文件等。

看一眼圖吧：

全部源碼：

 1 package com.bvin.exec;
  2
  3 import java.io.IOException;
  4 import java.net.MalformedURLException;
  5 import java.net.URL;
  6 import java.util.concurrent.ExecutorService;
  7 import java.util.concurrent.Executors;
  8
  9 import android.app.Activity;
10 import android.graphics.drawable.Drawable;
11 import android.os.AsyncTask;
12 import android.os.Bundle;
13 import android.os.Handler;
14 import android.os.HandlerThread;
15 import android.os.Message;
16 import android.util.Log;
17 import android.view.View;
18 import android.widget.Button;
19 import android.widget.ImageView;
20
21 public class MainActivity extends Activity {
22     /** Called when the activity is first created. */
23    
24     private Handler handler ;
25     private Button bt;
26     private Handler mainHandler = new Handler(){
27
28         @Override
29         public void handleMessage(Message msg) {
30             // TODO Auto-generated method stub
31             super.handleMessage(msg);
32             if(msg.what == 2012){
33                 //只要在主線程就可以處理ui
34                 ((ImageView)MainActivity.this.findViewById(msg.arg1)).setImageDrawable((Drawable)msg.obj);
35             }
36         }
37        
38        
39     };
40    
41     private ExecutorService service = Executors.newFixedThreadPool(5);
42    
43     @Override
44     public void onCreate(Bundle savedInstanceState) {
45         super.onCreate(savedInstanceState);
46         setContentView(R.layout.main);
47         initViews();
48         HandlerThread ht = new HandlerThread("down image thread");
49         ht.start();
50         handler = new Handler(ht.getLooper()){//如果有了looper那么這個(gè)handler就不可以處理ui了
51
52             @Override
53             public void handleMessage(Message msg) {
54                 // TODO Auto-generated method stub
55                 super.handleMessage(msg);
56                
57                
58             }
59            
60         };
61        
62     }
63    
64     private void initViews(){
65        
66         bt = (Button)findViewById(R.id.bt);
67         bt.setOnClickListener(new View.OnClickListener() {
68            
69             @Override
70             public void onClick(View v) {
71                 // TODO Auto-generated method stub
72                 loadImagesByExecutors("http://news.baidu.com/z/resource/r/image/2012-11-23/23c1625aca99f02c50d8e510383a34e7.jpg",R.id.iv1);
73                 loadImagesByExecutors("http://news.baidu.com/z/resource/r/image/2012-11-23/c4698d97ef6d10722c8e917733c7beb3.jpg",R.id.iv2);
74                 loadImagesByExecutors("http://news.baidu.com/z/resource/r/image/2012-11-23/f332ffe433be2a3112be15f78bff5a40.jpg",R.id.iv3);
75                 loadImagesByExecutors("http://news.baidu.com/z/resource/r/image/2012-11-23/6ff8a9c647a1e80bc602eeda48865d4c.jpg",R.id.iv4);
76                 loadImagesByExecutors("http://news.baidu.com/z/resource/r/image/2012-11-23/f104d069f7443dca52a878d779392874.jpg",R.id.iv5);
77             }
78         });
79     }
80    
81     private void loadImagesByHandler(final String url,final int id){//通過(guò)擁有l(wèi)ooper的handler.post(runnable)，新建線程
82        
83        
84         handler.post(new Runnable(){//如果handler沒(méi)有Looper那么它就不能構(gòu)建新線程了
85
86             @Override
87             public void run() {
88                 // TODO Auto-generated method stub
89                 Log.e("當(dāng)前線程：", ""+Thread.currentThread().getName());
90                 Drawable drawable = null;
91                 try {
92                     drawable = Drawable.createFromStream(new URL(url).openStream(), "image.gif");
93                 } catch (MalformedURLException e) {
94                     // TODO Auto-generated catch block
95                     e.printStackTrace();
96                 } catch (IOException e) {
97                     // TODO Auto-generated catch block
98                     e.printStackTrace();
99                 }
100                 //SystemClock.sleep(2000);
101                 //((ImageView)MainActivity.this.findViewById(id)).setImageDrawable(drawable);
102                 Message msg = mainHandler.obtainMessage();
103                 msg.what = 2012;
104                 msg.arg1 = id;
105                 msg.obj = drawable;
106                 msg.sendToTarget();
107             }
108            
109         });
110        
111        
112     }
113    
114     private void loadImagesByThread(final String url,final int id){//通過(guò)Thread來(lái)new 出多個(gè)線程
115        
116         new Thread(new Runnable(){
117
118             @Override
119             public void run() {
120                 // TODO Auto-generated method stub
121                 Log.e("當(dāng)前線程：", ""+Thread.currentThread().getName());
122                 Drawable drawable = null;
123                 try {
124                     drawable = Drawable.createFromStream(new URL(url).openStream(), "image.gif");
125                 } catch (MalformedURLException e) {
126                     // TODO Auto-generated catch block
127                     e.printStackTrace();
128                 } catch (IOException e) {
129                     // TODO Auto-generated catch block
130                     e.printStackTrace();
131                 }
132                 Message msg = mainHandler.obtainMessage();
133                 msg.what = 2012;
134                 msg.arg1 = id;
135                 msg.obj = drawable;
136                 msg.sendToTarget();
137                
138             }
139            
140         }).start();
141     }
142
143     private void loadImageByAsyncTask(final String url,final int id){//構(gòu)建異步任務(wù)，這樣就不用handler來(lái)處理消息了
144         DownloadTask task = new DownloadTask();
145         task.execute(""+id,url);//AsyncTask不可重復(fù)執(zhí)行
146     }
147    
148     private void loadImagesByExecutors(final String url,final int id){
149         service.submit(new Runnable(){
150            
151             @Override
152             public void run() {
153                 // TODO Auto-generated method stub
154                 Log.e("當(dāng)前線程：", ""+Thread.currentThread().getName());
155                
156                 try {
157                     final Drawable drawable  = Drawable.createFromStream(new URL(url).openStream(), "image.gif");
158                     mainHandler.post(new Runnable(){
159
160                         @Override
161                         public void run() {//這將在主線程運(yùn)行
162                             // TODO Auto-generated method stub
163                             ((ImageView)MainActivity.this.findViewById(id)).setImageDrawable(drawable);
164                         }
165                     });
166                    
167                 } catch (MalformedURLException e) {
168                     // TODO Auto-generated catch block
169                     e.printStackTrace();
170                 } catch (IOException e) {
171                     // TODO Auto-generated catch block
172                     e.printStackTrace();
173                 }
174                
175             }
176            
177         });
178        
179     }
180    
181     class DownloadTask extends AsyncTask{
182
183         int id;
184         @Override
185         protected Drawable doInBackground(String... params) {//params保存url和控件id兩個(gè)數(shù)據(jù)
186             // TODO Auto-generated method stub
187             Log.e("當(dāng)前線程：", ""+Thread.currentThread().getName());
188             Drawable drawable = null;
189             this.id = Integer.parseInt(params[0]);
190             try {
191                 drawable = Drawable.createFromStream(new URL(params[1]).openStream(), "image.gif");
192             } catch (MalformedURLException e) {
193                 // TODO Auto-generated catch block
194                 e.printStackTrace();
195             } catch (IOException e) {
196                 // TODO Auto-generated catch block
197                 e.printStackTrace();
198             }
199            
200             return drawable;
201         }
202
203         @Override
204         protected void onPostExecute(Drawable result) {
205             // TODO Auto-generated method stub
206             super.onPostExecute(result);
207             ((ImageView)MainActivity.this.findViewById(id)).setImageDrawable(result);
208         }
209
210         @Override
211         protected void onPreExecute() {
212             // TODO Auto-generated method stub
213             super.onPreExecute();
214         }
215
216         @Override
217         protected void onProgressUpdate(Integer... values) {
218             // TODO Auto-generated method stub
219             super.onProgressUpdate(values);
220         }
221
222        
223     }
224 }