import time 
import threading 
def p(i): 
 print i 
class task(threading.Thread): 
 def __init__(self,fun,i): 
 threading.Thread.__init__(self) 
 self.fun = fun 
 self.i = i 
 self.thread_stop = False 
 def run(self): 
 while not self.thread_stop: 
 self.fun(self.i) 
 def stop(self): 
 self.thread_stop = True 
def test(): 
 thread1 = task(p,2) 
 thread1.start() 
 time.sleep(4) 
 thread1.stop() 
 return 
if __name__ == '__main__': 
 test()

#!/usr/bin/env python 
#-*-coding:utf-8-*- 
''''' 
author:cogbee 
time:2014-6-13 
function:readme 
''' 
import pdb 
import time 
import threading 
import os 
#pdb.set_trace() 
class task(threading.Thread): 
 def __init__(self,ip): 
 threading.Thread.__init__(self) 
 self.ip = ip 
 self.thread_stop = False 
 def run(self): 
 while not self.thread_stop: 
 #//添加你要做的事情，如果成功了就設(shè)置一下self.thread_stop變量。 
[python] view plaincopy在CODE上查看代碼片派生到我的代碼片
 if file != '': 
 self.thread_stop = True 
 def stop(self): 
 self.thread_stop = True 
def test(eachline): 
 global file 
 list = [] 
 for ip in eachline: 
 thread1 = task(ip) 
 thread1.start() 
 thread1.join(3) 
 if thread1.isAlive(): 
 thread1.stop() 
 continue 
 #將可以讀取的都存起來 
 if file != '': 
 list.append(ip) 
 print list 
if __name__ == '__main__': 
 eachline = ['1.1.1.1','222.73.5.54'] 
 test(eachline)

import threading 
import inspect 
import ctypes 
def _async_raise(tid, exctype):
 """raises the exception, performs cleanup if needed"""
 if not inspect.isclass(exctype):
 raise TypeError("Only types can be raised (not instances)")
 res = ctypes.pythonapi.PyThreadState_SetAsyncExc(tid, ctypes.py_object(exctype))
 if res == 0:
 raise ValueError("invalid thread id")
 elif res != 1:
 # """if it returns a number greater than one, you're in trouble, 
 # and you should call it again with exc=NULL to revert the effect"""
 ctypes.pythonapi.PyThreadState_SetAsyncExc(tid, 0)
 raise SystemError("PyThreadState_SetAsyncExc failed")
class Thread(threading.Thread):
 def _get_my_tid(self):
 """determines this (self's) thread id"""
 if not self.isAlive():
 raise threading.ThreadError("the thread is not active")
 # do we have it cached?
 if hasattr(self, "_thread_id"):
 return self._thread_id
 # no, look for it in the _active dict
 for tid, tobj in threading._active.items():
 if tobj is self:
 self._thread_id = tid
 return tid
 raise AssertionError("could not determine the thread's id")
def raise_exc(self, exctype):
 """raises the given exception type in the context of this thread"""
 _async_raise(self._get_my_tid(), exctype)
def terminate(self):
 """raises SystemExit in the context of the given thread, which should 
 cause the thread to exit silently (unless caught)"""
 self.raise_exc(SystemExit)

>>> import time 
>>> from thread2 import Thread 
>>> 
>>> def f(): 
... try: 
... while True: 
... time.sleep(0.1) 
... finally: 
... print "outta here" 
... 
>>> t = Thread(target = f) 
>>> t.start() 
>>> t.isAlive() 
True 
>>> t.terminate() 
>>> t.join() 
outta here 
>>> t.isAlive() 
False