ブロッキングスレッドを強制終了する

Question

私はスレッドがネットワーク上でREST呼び出しを行うスレッドアプリケーションを開発しようとしています。

特定のタイムアウト後にアクティブなスレッドを強制終了する必要があります。私はここで見てきたすべてのpython 2.7.xのアプローチを試してきましたが、これを得ることはできません。

OEL linux（3.8.13-44.1.1.el6uek.x86_64）でpython 2.7.6を使用しています。ここで

は、コードの簡略化スニペットです：

class cthread(threading.Thread): 
    def __init__(self, cfg, host): 
     self.cfg = cfg 
     self.host = host 
     self.runf = False 
     self.stop = threading.Event() 
     threading.Thread.__init__(self. target=self.collect) 

    def terminate(self): 
     self.stop.set() 

    def collect(self): 
     try: 
      self.runf = True 
      while (not self.stop.wait(1)): 
       # Here I do urllib2 GET request to a REST service which could hang 
       <rest call> 
     finally: 
      self.runf = False 

timer_t1 = 0 

newthr = cthread(cfg, host) 
newthr.start() 

while True: 
    if timer_t1 > 600: 
     newthr.terminate() 
     break 
    time.sleep(30) 
    timer_t1 += 30 

基本的に私のタイムアウト時間の後、私はどちらか正常かどうか、残りのすべてのスレッドを殺すために必要があります。

これを動作させるには時間がありません。

私は正しい方法を考えていますか？

Answer 1

Pythonでスレッドを強制終了する公式のAPIはありません。あなたが定期的にメインループから実行してタイムアウトオプションでurllib2のを使用するようにスレッド放置タイムアウトを渡すかもしれないurllib2のに頼って自分のコードで

。あるいは、urllib2で同じ手法を利用してスレッド内のタイマーを追跡することさえできます。