pythonマルチスレッド処理繰返しタスク10000回
1617 ワード
#!/usr/bin/python
import threading
import urllib2
#f = open("/root/wget.txt","a")
x = [ i.strip() for i in open("/root/ceshi/abc.txt","r") ]
#f1 = open("/root/abc.txt","r")
def wget(x):
response = urllib2.urlopen("http://abc.abc.com/organize/domain/allupdate?domainname=%s"%x)
if response.read() == '{"code": "0", "data": "ok"}':
f.write('%s {"code": "0", "data": "ok"}
'%x)
else:
f.write('%s {"code": "0", "data": "fail"}
'%x)
def main():
n = 0
while len(x) - n >= 20:
f = open("/root/ceshi/wget.txt","a")
threads = []
for i in range(n+0,n+20):
t = threading.Thread(target=wget,args=(x[i],))
threads.append(t)
for i in range(20):
threads[i].start()
for i in range(20):
threads[i].join()
n+=20
f.close()
f = open("/root/ceshi/wget.txt","a")
for i in range(n,len(x)):
threads = []
t = threading.Thread(target=wget,args=(x[i]))
threads.append(t)
for i in range(len(x)-n):
threads[i].start()
for i in range(len(x)-n):
threads[i].join()
f.close()
if __name__ == '__main__':
main()