Многопоточная передача в Python - PullRequest
Новая
       10

Многопоточная передача в Python

0 голосов
/ 19 декабря 2018

Я использую 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 ".

Пожалуйста,Пожалуйста, помогите мне решить эту проблему.

Спасибо.

1 Ответ

0 голосов
/ 19 декабря 2018

Вы используете локальную переменную i, которая за это время изменилась.Передайте это так: 

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

И добавьте его в качестве аргумента в функцию loop: 

def loop(i):
    ...
...