当前位置: 首页 > 面试题库 >

Android Service类中的哪里停止/销毁线程?

萧和平
2023-03-14
问题内容

我通过以下方式创建了线程服务:

public class TCPClientService extends Service{  
...

@Override
public void onCreate() {
    ...
    Measurements = new LinkedList<String>();
    enableDataSending();    
}

@Override
public IBinder onBind(Intent intent) {
    //TODO: Replace with service binding implementation
    return null;
}

@Override
public void onLowMemory() {
    Measurements.clear();
    super.onLowMemory();
}

@Override
public void onDestroy() {
    Measurements.clear();
    super.onDestroy();
    try {
        SendDataThread.stop();
    } catch(Exception e){
        ...     
    }

}

private Runnable backgrounSendData = new Runnable() {

    public void run() {
        doSendData();
    }
};

private void enableDataSending() {
    SendDataThread = new Thread(null, backgrounSendData, "send_data");
    SendDataThread.start();
}

 private void addMeasurementToQueue() {
     if(Measurements.size() <= 100) {
         String measurement = packData();
         Measurements.add(measurement);
     }
 }

 private void doSendData() {
     while(true) {
         try {      
             if(Measurements.isEmpty()) {
                 Thread.sleep(1000);
                 continue;
             }
             //Log.d("TCP", "C: Connecting...");
             Socket socket = new Socket();
             socket.setTcpNoDelay(true);
             socket.connect(new InetSocketAddress(serverAddress, portNumber), 3000);
             //socket.connect(new InetSocketAddress(serverAddress, portNumber));
             if(!socket.isConnected()) {
                 throw new Exception("Server Unavailable!");
             }
             try {
                 //Log.d("TCP", "C: Sending: '" + message + "'");
                 PrintWriter out = new PrintWriter( new BufferedWriter( new OutputStreamWriter(socket.getOutputStream())),true);
                 String message = Measurements.remove();
                 out.println(message);
                 Thread.sleep(200);
                 Log.d("TCP", "C: Sent.");
                 Log.d("TCP", "C: Done.");
                 connectionAvailable = true;              
             } catch(Exception e) {
                 Log.e("TCP", "S: Error", e);
                 connectionAvailable = false;
             } finally {
                 socket.close();
                 announceNetworkAvailability(connectionAvailable);
             }
         } catch (Exception e) {
             Log.e("TCP", "C: Error", e);
             connectionAvailable = false;
             announceNetworkAvailability(connectionAvailable);
         }
    }
}

...
}

关闭应用程序后,电话的工作速度非常慢,我猜这是由于线程终止失败引起的。

有谁知道在终止应用程序之前终止所有线程的最佳方法是什么?


问题答案:

附录
:Android框架为一次性工作,后台工作等提供了许多帮助程序,与在许多情况下尝试滚动自己的线程相比,它们可能更可取。如下面的文章所述,AsyncTask是一个很好的起点。我鼓励读者在开始考虑自己编写线程之前先研究一下框架规定。

您发布的代码示例中有几个问题,我将按顺序解决:

1)Thread.stop()已被弃用一段时间,因为在某些情况下,它可能会使因变量处于不一致状态。有关更多详细信息,请参见此Sun答案页面(编辑:该链接现在已失效,对于为何不使用Thread.stop()的信息,请参见此页面)。停止和启动线程的首选方法如下(假设您的线程将无限期地运行):

private volatile Thread runner;

public synchronized void startThread(){
  if(runner == null){
    runner = new Thread(this);
    runner.start();
  }
}

public synchronized void stopThread(){
  if(runner != null){
    Thread moribund = runner;
    runner = null;
    moribund.interrupt();
  }
}

public void run(){
  while(Thread.currentThread() == runner){
    //do stuff which can be interrupted if necessary
  }
}

这只是如何停止线程的一个示例,但总的来说,您有责任像退出其他任何方法一样退出线程。维护跨线程通信的方法(在这种情况下为易失性变量,也可以通过互斥锁等),并在线程逻辑内,使用该通信方法检查是否应及早退出,清理等。

2)您的度量值列表可以同时被多个线程(事件线程和用户线程)访问,而不会进行任何同步。看起来您不必进行自己的同步,可以使用BlockingQueue。

3)您将在发送线程的每次迭代中创建一个新的Socket。这是一项相当繁重的操作,并且只有在您希望很少进行测量(例如每小时一小时或更短)的情况下才有意义。您需要一个不会在线程的每个循环中都重新创建的持久套接字,或者想要一个可运行的快照,可以“触发并忘记”它创建一个套接字,发送所有相关数据并完成操作。(有关使用持久套接字的快速说明,阻塞的套接字方法(例如读取)不能被Thread.interrupt()中断,因此,当您要停止线程时,必须关闭套接字并调用中断)

4)从线程内引发您自己的异常没有什么意义,除非您希望将其捕获到其他地方。更好的解决方案是记录该错误,如果无法恢复,则停止线程。线程可以使用以下代码停止自身(在与上述相同的上下文中):

public void run(){
    while(Thread.currentThread() == runner){
      //do stuff which can be interrupted if necessary

      if(/*fatal error*/){
        stopThread();
        return; //optional in this case since the loop will exit anyways
      }
    }
  }

最后,如果要确保线程随应用程序的其余部分一起退出,那么不管怎样,一种好的方法是在创建线程之后和启动线程之前调用Thread.setDaemon(true)。这会将线程标记为守护程序线程,这意味着如果没有非守护程序线程正在运行(例如,如果您的应用程序退出),则VM将确保将其自动销毁。

遵循关于线程的最佳实践应确保您的应用不会挂起或降低电话速度,尽管它们可能非常复杂:)



 类似资料:
  • 我有一个片段,它设置一个列表视图,并创建一个处理程序来定期更新列表视图。然而,看起来处理程序在片段被销毁后仍然运行。 以下是代码。 在被销毁后更新会导致应用程序崩溃。如何在被销毁时使停止?我还想知道如果应用程序的任何暂停对也有什么影响。

  • 问题内容: 我正在编写一段连接到服务器的代码,使用该连接会生成一堆线程并执行一堆“工作”。 在某些情况下,连接失败,我需要停止所有操作并从头开始创建新对象。 我想在对象之后进行清理,但在线程上调用thread.stop,但是此方法似乎已被弃用。 推荐的替代方法是什么?是否应该为每个线程编写自己的清理和退出方法?将线程设置为null?或者是其他东西? 问题答案: 看这里 : 在HowToStopAT

  • 我有一个带有片段页面管理器的视图页面管理器,我的应用程序以前只使用了两个片段(不同类型的)而没有问题。 不过,我刚刚添加了第三个片段,现在当我远离它们时,我的适配器/视图寻呼机似乎正在破坏我的片段。例如,如果我在第1页,当我靠近它时,第3页会被销毁并重新创建。如果我在第3页,第1页也会发生同样的事情。 这会导致我的应用出现很多问题。这些碎片根本不是RAM,所以我如何阻止这种情况发生?

  • 我已经查看了这里给出的一些ANWER,但我没有得到解决我问题的确切方法:我不想创建一个新的类并扩展runnable或Thread。 我有一个服务,它在创建时必须每10秒检查一些东西,并且所需的调用不能从主线程执行,所以在StartCommand()方法中我执行以下操作: 现在,当我调用onStopService()时,我想停止这个线程。方法stop()不推荐使用,因此我使用中断(): 正如我预期的

  • 销毁 Destroy 在不需要使用iScoll的时候调用iScroll实例的公共方法destroy()可以释放一些内存。 myScroll.destroy(); myScroll = null;

  • 问题内容: 我对垃圾收集器在Java中的工作方式有一个大致的了解,但是我销毁对象的原因不是因为我关心释放内存,而是因为功能。我可以用一个例子更好地解释: 假设我正在制作涉及金钱的游戏。当某人从地面上捡起一个物体时,我想调用该物体的方法,该方法涉及为该人的钱包添加一个值。 之后发现,我不希望别人能够把它捡起来。换句话说,我不希望自己或任何其他程序能够不经意间拨打电话: 因此,在Bob拿起钱后,它的价