Jak korzystać z puli wątków, aby wykonać funkcję nieskończonej pętli?

Question

Chcę wykonać funkcję nieskończonej pętli.

Oto mój kod

def do_request(): 
    # my code here 
    print(result) 

while True: 
    do_request() 

Kiedy użycie while True to zrobić, to jest trochę powolny, więc chcę używać puli wątków do równoczesnego wykonywania funkcji do_request(). Jak to zrobić ?

Podobnie jak użycie ab (ławka Apache) do testowania serwera HTTP.

Answer 1

Wreszcie, mam rozwiązać ten problem. Używam zmiennej do ograniczenia numeru wątku.

Oto mój ostateczny kod, rozwiązałem mój problem.

import threading 
import time 

thread_num = 0 
lock = threading.Lock() 

def do_request(): 
    global thread_num 
    # ------------- 
    # my code here 
    # ------------- 
    with lock: 
     thread_num -= 1 

while True: 
    if thread_num <= 50: 
     with lock: 
      thread_num += 1 
     t = threading.Thread(target=do_request) 
     t.start() 
    else: 
     time.sleep(0.01) 

Dzięki za wszystkie odpowiedzi.

Answer 2

Możesz użyć threading w Pythonie, aby to zaimplementować. Może być coś podobnego do tego (przy użyciu tylko dwa dodatkowe wątki):

import threading 

# define threads 
task1 = threading.Thread(target = do_request) 
task2 = threading.Thread(target = do_request) 

# start both threads 
task1.start() 
task2.start() 

# wait for threads to complete 
task1.join() 
task2.join() 

Zasadniczo, można uruchomić dowolną liczbę wątków, jak trzeba (upewnij się, że nie zbyt wiele, więc system może obsłużyć), następnie należy je odczekać, aż zadania zakończą się.

Lub można uzyskać bardziej zaawansowany z modułem Python multiprocessing.

Answer 3

Wypróbuj poniższy kod:

import multiprocessing as mp 
import time 

def do_request(): 
    while(True): 
     print('I\'m making requests') 
     time.sleep(0.5) 


p = mp.Process(target=do_request) 
p.start() 

for ii in range(10): 
    print 'I\'m also doing other things though' 
    time.sleep(0.7) 

print 'Now it is time to kill the service thread' 
p.terminate() 

The głównych gwiazd nici wątku usługa, która wykonuje żądania i idzie dalej, aż musi, a potem kończy się wątek serwisowym.

Answer 4

Może użyć concurrent.futures.ThreadPoolExecutor

from concurrent.futures import ThreadPoolExecutor 
import time 

def wait_on_b(hello): 
    time.sleep(1) 
    print(hello) # b will never complete because it is waiting on a. 
    return 5 

def wait_on_a(): 
    time.sleep(1) 
    print(a.result()) # a will never complete because it is waiting on b. 
    return 6 


executor = ThreadPoolExecutor(max_workers=2) 
a = executor.submit(wait_on_b, 3) 
b = executor.submit(wait_on_a) 

Answer 5

Jak na ten temat?

from threading import Thread, Event 

class WorkerThread(Thread): 
    def __init__(self, logger, func): 
      Thread.__init__(self) 
      self.stop_event = Event() 
      self.logger = logger 
      self.func = func 

    def run(self): 
      self.logger("Going to start the infinite loop...") 
      #Your code 
      self.func() 

concur_task = WorkerThread(logger, func = do_request) 
concur_task.start() 

Aby zakończyć ten wątek ...

concur_task.stop_event.set() 
concur_task.join(10) #or any value you like