现在的位置: 首页 > 综合 > 正文

强行关掉超时的线程还是让它自己退出

2013年09月28日 ⁄ 综合 ⁄ 共 2131字 ⁄ 字号 评论关闭

      
在编写网络传输代码中有一个逃不掉的问题就是网络突然断掉,程序就会像死机一样等待在那里,当然你可以设置超时然后潇洒的退出。但是当你使用的不是使用Socket直接编写,而且你无法设置超时时间,这时你又怎么办呢?

当然我们也有办法,就是开启一个线程A将进行网络通信的代码放在线程函数中处理,这是主线程就使用WaitSingleObject函数(这里就已Windows下的函数为例说明)设置好超时时间,进行等待,到时间主线程就会恢复响应。但是问题来了当超时发生了,主线程可以恢复响应,但刚才开启的线程A如何处理,放在那里不管,当然不行。那如何管?直接terminate掉线程A?这恐怕是很多人的选择。随便在网上查一下也知道,直接terminate掉线程是不可取的,它的危险性我就不多说了,如果你没遇到算你走远。现在我们来看看有没有好的方法可以让线程从容的自己退出。

      
让线程自己从容的退出,你肯定会说我是不是傻了,线程A都没有响应了你能怎么办。我当然有我的办法。请看下面的例子:下面就简写主要的函数和变量

CAThread : public CWinThread{

private:

      
volialte   BOOL    bifFinish;

public:

      
virtual    int  Run();

                    
BOOL    GetIfFinish() {  return bifFinish; 
}

                    
void Stop();

}

 

 

CAThread::Run()

{

      
bifFinish = FALSE;

      
..

      
try{

CSocket.write() ;                      
//    
这里只是代表进行网络通信

      
….

      
}catch(){

             
....

}

      
bifFinish = TRUE;

      
return 0;

}

这里提供了一个很关键的函数,让我们看看我们如何停到线程的吧。

CAThread::Stop()

{

      
CSocket.Close();

}

对我们没有别的办法,我们将进行通信的通道给关掉。这样try…catch块就会出现异常。出现了异常线程就不会一直等待,会进入异常处理,异常处理完成线程就会返回。

哈哈,线程现在可以自己退出了,我们实现了我们的目标,到这里就完了吗?没有。让我们来看看在等待线程结束函数里面我们还有做些什么。

 

CAThread athread =
new CAThread ();

athread ->CreateThread();

DWORD dw = ::WaitForSingleObject(athread->m_hThread,10*1000);

   
BOOL frc = FALSE;

   
switch(dw){

       
case WAIT_OBJECT_0:
{               //success finish

                   
break;

               
}

       
case WAIT_TIMEOUT:{

                   
m_csErr = _T("
连接超时,请检查网络连接或服务器配置");

                   
athread->Stop();            //
这里我们调用了结束线程函数

                   
break;

               
}

       
case WAIT_FAILED:{

                   
m_csErr = _T("
请检查网络连接或服务器配置");

                   
athread->Stop();            //
这里我们调用了结束线程函数

                   
break;

               
}

   
}

   
//
下面是关键点……….

   
if ( !m_phttpThread->GetIfFinish()){

       
dw = ::WaitForSingleObject(m_phttpThread->m_hThread,5*1000);

   
}

 

   
我们已经调用了关闭线程的函数,但是线程响应异常,进行异常处理也还需要时间,那我们不能就这样离开主线程不管子线程了。我们在子线程中设置了一个变量ifFinish
当子线程执行到结尾时会将这个变量置为真,这样我们知道子线程中已经没有我们需要执行和管理的代码了,我们可以潇洒的离开了。如果子线程的异常处理还没有完成则我们就再一次等待该子线程,当然这是不会花去太多时间的,因为子线程的异常处理工作我们一般也不会安排很多很复杂的逻辑。

   
这样我们就利用多线程的方式很好的实现了对超时线程的安全退出。当然这样做肯定比不了直接关闭线程来的快,但是比起会出现的各种不确定的错误,我还是愿意选择安全的做法。

   
当然你发生超时的情况不同,你也可以选择不同的方法,变通在你,我这里只是抛砖引玉希望能给喜欢Terminate掉线程的朋友一点提示。

抱歉!评论已关闭.