本文实例讲述了Python实现可设置持续运行时间,线程数及时间间隔的多线程异步后请求功能。分享给大家供大家参考,具体如下:
#=utf8编码
“‘
随机的。randint (a, b):用于生成一个指定范围内的整数。
一个是其中参数下限,参数b是上限,生成的随机数n: & lt;=n & lt;=b
random.choice(序列):从序列中获取一个随机元素
参数序列表示一个有序类型(列表,元组,字符串)
“‘
,的进口httplib的json
导入的时间
进口线程
从随机进口randint,选择
#创建请求函数
def postRequest (threadNum):
postJson={
}
#定义需要进行发送的数据
postData=https://www.yisu.com/zixun/json.dumps (postJson)
#定义一些文件头
headerdata={“内容类型”:“application/json”,
}
#接口
requrl="/v1/查询”
#请求服务,例如:www.baidu.com
hostServer=" "
#连接服务器
康涅狄格州=httplib.HTTPConnection (hostServer)
#发送请求
conn.request(方法=" POST "、url=requrl身体=postData header=headerdata)
#获取请求响应
响应=conn.getresponse ()
#打印请求状态
如果响应。在范围(200300):
打印u”线程”+ str (threadNum) + u”状态码:”+ str (response.status)
conn.close ()
def运行(threadNum internTime,持续时间):
#创建数组存放线程
线程=[]
试一试:
#创建线程
我的范围(1,threadNum):
#针对函数创建线程
t=threading.Thread(目标=postRequest args=(我))
#把创建的线程加入线程组
threads.append (t)
除了例外,e:
打印e
试一试:
#启动线程
线程的线程:
thread.setDaemon(真正的)
thread.start ()
time . sleep (internTime)
#等待所有线程结束
线程的线程:
thread.join(持续时间)
除了例外,e:
打印e
if __name__==癬_main__”:
Y startime=time.strftime (“% % m % d % H % m % S”)
现在=time.strftime (“% Y % m % d % H % m % S”)
duratiion=raw_input (u”输入持续运行时间:“)
而(startime + str (duratiion)) !=现在:
运行(10 1 int (duratiion))
现在=time.strftime (“% Y % m % d % H % m % S”)
之前
运行结果:
更多关于Python相关内容可查看本站专题:《Python套接字编程技巧总结》,《Python数据结构与算法教程》、《Python函数使用技巧总结》,《Python字符串操作技巧汇总》、《Python入门与进阶经典教程》及《Python文件与目录操作技巧汇总》
希望本文所述对大家Python程序设计有所帮助。
