#coding=utf-8 import httplib from time import ctime import threading import csv #测试数据存放文件路径和文件 peopleinfo = "C:\\Users\\ewang\\Desktop\\Infor.csv" #url="C:\\Users\\ewang\\Desktop\\UrlInfo.csv" #创建文件句柄并赋
import httplib
from time import ctime
import threading
import csv
#测试数据存放文件路径和文件
peopleinfo="C:\\Users\\ewang\\Desktop\\Infor.csv"
#url="C:\\Users\\ewang\\Desktop\\UrlInfo.csv"
#创建文件句柄并赋予该文件读权限
userInfo=file(peopleinfo,"rb")
#UrlFile=file(url,"w+")
#Url=open(url,"w+")
#创建请求函数
def Clean():
#获取文件中的信息
reader=csv.reader(userInfo)
#获取文件中每行的信息
for line in reader:
#接口的url
requrl = "http://服务器IP/service/clean?uid=0&client="+line[2]+"&deviceId="+line[0]
#连接服务器
conn = httplib.HTTPConnection("服务器IP")
#发送请求
conn.request(method="GET",url=requrl)
#获取请求响应
response=conn.getresponse()
#打印请求状态
print response.status
#创建数组存放线程
threads=[]
#创建100个线程
for i in range(100):
#针对函数创建线程
t=threading.Thread(target=Clean,args=())
#把创建的线程加入线程组
threads.append(t)
print 'start:', ctime()
if __name__ == '__main__':
#启动线程
for i in threads:
i.start()
#keep thread
for i in threads:
i.join()
print 'end:', ctime()
#Url.close()
#关闭数据文件
userInfo.close()