Python中的多线程传输

Question

我使用 Python Client 连接 Netty 服务器。

客户：

import socket 
from datetime import datetime
import csv
import threading
import sys
import time

starttimes = sys.argv[1]
starttimes = int(starttimes)
endtimes = sys.argv[2]
endtimes = int(endtimes)
times = endtimes - starttimes

open('result.csv','w').close()
csv_file = 'result.csv'

def loop():
    TCP_IP = "127.0.0.1"
    TCP_PORT = 9999                   # The same port as used by the server
    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    s.connect((TCP_IP, TCP_PORT))
    timereq = datetime.now()
    timereq2 = datetime.strftime(timereq, '%Y-%m-%d,%H:%M:%S.%f')
    timereq3 = time.time()
    s.sendall("\x00\x00"+i)
    res = s.recv(4096)
    print res
    timeres = datetime.now()
    timeres2 = datetime.strftime(timeres, '%Y-%m-%d,%H:%M:%S.%f')
    timeres3 = time.time()
    s.close()
    print('Received', repr(res))
    cost = timeres3 - timereq3
    cost = "%.3f" % cost
    with open(csv_file, 'a') as csvfile:

        writer = csv.writer(csvfile)
        writer.writerow([timereq2, timeres2, cost])


threads = []
for i in range(starttimes,endtimes+1):
    i =chr(i)
    t = threading.Thread(target=loop)
    threads.append(t)
    t.start()

例如，我在多线程中设置变量“i”在 1 到 10 之间，服务器中的理想结果是得到“i = 1, 2, 3, 4, 5, 6, 7, 8, 9, 10 ”。

但有时它会出错，例如“i = 1, 2, 2, 4, 5, 7, 7, 8, 9, 10”或“i = 3, 3, 3, 3, 5, 5、5、8、9、9"。

请帮我解决问题。

谢谢。

Answer 1

您正在使用同时发生变化的局部变量i。 像这样传递它：

threading.Thread(target=loop, args=(i,))

并将其作为参数添加到loop 函数：

def loop(i):
    ...