我通过以下方式创建了线程服务:
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拿起钱后,它的价