BroadcastReceiver 是否足够异步以使其工作

Question

想要停止线程进行一些下载。
当我只有 stopNow = true; 并且没有发生阻塞时，下面的代码工作正常。
我创建了 boolean stopNow = false; 作为 IntentService 中的一个字段。

由于 stopNow 仅当连接在 while 循环中进行时才起作用
但如果 f.ex 连接陈旧并开始阻塞，它就不起作用。

我想添加这段代码来真正阻止阻塞。

if(socket != null){
    socket.shutdownOutput();
    socket.shutdownInput();
}

问题是这是否是异步的，因此执行是否正在
while 循环 stopNow = true; 将停止它，我可以在 stopNow = true; 之后放置一个 sleep(5000)，然后是 <仅当 stopNow 无效时，code>if(socket != null) 才会为 true。

希望你关注我..

位于 run() 内的 BroadcastReceiver：

private class MyIncomingListener extends BroadcastReceiver {

    @Override
    public void onReceive(Context context, Intent intent) {

        if(intent.getAction().equals(Consts.COM_CARLSBERG_STOPOUTGOING)) {
            String b = intent.getStringExtra(Consts.COM_CARLSBERG_BATCHUUID);
            if(b != null){
                if(b.equals(batch.batchUuid)){
                    stopNow = true;
                    // sleep(5000) wait for stopNow to take effect
                    // if socket=null then stopNow did it's job
                    // if socket is alive then there is blocking to unblock
                try{
                    if(socket != null){
                        socket.shutdownOutput();
                        socket.shutdownInput();
                    }
                } catch (Exception e) {}
               }    
            }
        }
    }
}

Answer 1

到目前为止这实际上运作良好

    stopNow = true;

try{
    if(socket != null){
        socket.shutdownOutput();
        socket.shutdownInput();
    }
} catch (Exception e) {}    

Answer 2

public final void stop ()
Since: API Level 1
This method is deprecated.
because stopping a thread in this manner is unsafe and can leave your application and the VM in an unpredictable state.

Requests the receiver Thread to stop and throw ThreadDeath. The Thread is resumed if it was suspended and awakened if it was sleeping, so that it can proceed to throw ThreadDeath.



 try {
                     int waited = 0;
                     while(_active && (waited < _splashTime)) {
                         sleep(100);
                         if(_active) {
                             waited += 100;
                         }
                     }
                 } catch(InterruptedException e) {
                     // do nothing
                 } finally {
                     finish();
                     Intent intent= new Intent(SplashActivity.this,LoginViewController.class);
                     startActivity(intent);

                     stop();
                 }