Sonsuz döngü işlevini yapmak için iş parçacığı havuzu nasıl kullanılır?

Question

Sonsuz döngü işlevi yapmak istiyorum.

İşte kullanılması while True bunu yaparken, biraz yavaş, bu yüzden aynı anda işlevini do_request() yürütmek için bir iş parçacığı havuzu kullanmak isteyen benim kod

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

while True: 
    do_request() 

olduğunu. Bu nasıl yapılır ?

HTTP sunucusunu test etmek için ab (Apache Bench) gibi kullanın.

Answer 1

Son olarak, bu sorunu çözdük. İplik numarasını sınırlamak için bir değişken kullanıyorum.

İşte son kodum, sorunumu çözdü.

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) 

Tüm yanıtlar için teşekkürler.

Answer 2

Bunu uygulamak için Python'da threading'u kullanabilirsiniz. Eğer çok fazla, bu nedenle sistem bunu işleyebilir alamadım emin olun (ihtiyaç olarak Temel olarak, birçok konuları başlatmak

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() 

: (iki ekstra konuları yalnızca kullanılırken) buna benzer bir şey olabilir), daha sonra görevleri tamamlamak için beklemek için .join().

Ya da multiprocessing Python modülü ile meraklısı alabilirsiniz.

Answer 3

aşağıdaki kodu deneyin:

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() 

ana iş parçacığı yıldızlı isteği yapar ve gereken kadar gider bir servis iplik ve daha sonra servis parçacığı kadar bitirir. Bu nasıl hakkında

Answer 4

Belki 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

kullanabilir?

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() 

Konuyu bitirmek için ...

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