如何在Android中停止線程處理程序？

Question

我剛剛在Android上開始了一個簡單的線程處理程序。代碼起作用。唯一的部分是如何關閉處理程序。我試圖關閉處理程序onPause（），但它只是繼續運行。有什麼建議麼？

下面是代碼： 我的主要活動主題：

package com.test.prog; 

import android.app.Activity; 
import android.os.Bundle; 
import android.os.Handler; 
import android.widget.TextView; 

public class AndroidThreadProgv1Activity extends Activity { 

    private Handler DataHandler; 

    private DataUpdater du; 
    /** Called when the activity is first created. */ 
    @Override 
    public void onCreate(Bundle savedInstanceState) { 
     super.onCreate(savedInstanceState);  
     setContentView(R.layout.main); 

     /* Initialize handler to allow UI updating in other threads */ 
     DataHandler = new Handler(); 

     startDataUpdater(); 

    } 

    public void onPause(){ 
     super.onPause(); 
     du.stopConnection(); 
    } 

    private void startDataUpdater(){ 
     System.out.println("In startDataUpdater"); 
     du = new DataUpdater(DataHandler,(TextView) findViewById(R.id.textView1)); 
     du.start(); 
    } 

} 

DataUpdater.java：

package com.test.prog; 

import java.io.IOException; 
import android.os.Handler; 
import android.os.Looper; 
import android.widget.TextView; 

/* 
* Data updater thread. Updates the display with the response. 
*/ 
public class DataUpdater extends Thread{ 

    /*Handler for the UI update*/ 
    private Handler dataRefreshHandler; 

    /*The UI text displaying the data*/ 
    private TextView dataLabel; 

    /*data value*/ 
    private int data = 0; 
    /*data update rate in ms*/ 
    private static final int dataUpdateRate = 2000; 

    private boolean stoppedFlag= false; 

    public DataUpdater(Handler handler, TextView tv){ 
     this.dataRefreshHandler = handler; 
     this.dataLabel = tv; 
    } 


    public void stopConnection() 
    { 
     if(this.dataRefreshHandler != null) { 
      this.dataRefreshHandler.removeMessages(data); // Remove a delayed message 
      System.out.println("In stopConnection"); 
      /* 
      if(!stoppedFlag){ 
       this.dataRefreshHandler.getLooper().quit(); // Warning 
       stoppedFlag = true; 
      } 
      */ 
     } 
    } 


    @Override 
    public void run(){ 
     try { 
      while(true){ 
       System.out.println("In run"); 
       data = data + 1;   
       updateData();    
       Thread.sleep(dataUpdateRate); 
      } 

     } 
     catch (InterruptedException e) { 
      e.printStackTrace(); 
     } 
    }  
    /* 
    * Calls the UI Handler and updates the display 
    */ 
    private void updateData(){ 
     dataRefreshHandler.post(new Runnable() { 
      public void run() { 
       if(data==0) 
       { 
        dataLabel.setText("Value not known"); 
       } 
       else 
       { 
        System.out.println("In update"); 
        dataLabel.setText("Value="+data); 

       } 
      } 
     }); 
    } 
} 

Answer 1

在dataUpdater你 「跑」 的方法有while(true)循環。你永遠不會檢查任何退出條件，所以它永遠不會停止。你可以做的是在DataUpdater中包含一個volatile標誌（初始設置爲true）並且stopConnection將其設置爲false。您在run中的while循環可以檢查該標誌，而不是僅僅循環無限。

爲了確保只要您的活動運行的DataUpdater運行：

移動從onCreate調用startDataUpdater();到onResume（安卓始終的onCreate後調用的onResume所以這將確保你總是在創建調用startDataUpdater爲以及暫停後重新開始）。

更改您的run方法在DataUpdater看起來像這樣：

public void run(){ 
    isRunning = true; // isRunning should be declared as a "private volatile boolean" 
    try { 
     while(isRunning){ 
      System.out.println("In run"); 
      data = data + 1;   
      updateData();    
      Thread.sleep(dataUpdateRate); 
     } 
    } 

Answer 2

您可以進行活套的用戶，而不是使用一段時間（1），這是CPU霸佔。 對於循環回來，您可以將消息發回到循環中的相同處理程序。 對於停止時，您只需將可運行的run（）方法中的runnable Looper.myLooper.stop（）發佈到活套。

Looper比While（true）更有效