特定のソケットからすべてのデータを受信するのにかかる時間を計算しようとしているので、「with Timeout(5, False)」を使用してデータを 5 秒間待機し、最後の受信時間を保存しています。ただし、現在のコードは、複数のスレッドを指定するとハングアップするだけです。タイムアウトする必要があるときにハングする理由を理解するのを手伝ってください。
#!/usr/bin/env python
import sys
import time
from gevent import socket, Timeout
from gevent.pool import Pool
def calc_wait(website):
data = ''
start = stop = time.time()
sock_buffer = ''
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect((website,80))
s.send('HEAD / HTTP/1.1\n\n')
with Timeout(5, False):
while True:
data = s.recv(1024)
if data:
sock_buffer += data
stop = time.time()
print ('Recieved {0} bytes in {1} seconds from {2}'
.format(len(sock_buffer), stop-start, s.getpeername()))
return 0
if __name__ == "__main__":
targs = ['google.com', 'yahoo.com', 'bing.com',\
'tide.com', 'monkey.com', 'python.com',\
'a.com', 'b.com', 'c.com', 'd.com']
pool = Pool(10)
for t in targs:
pool.spawn(calc_wait, t)
pool.join()