Comment puis-je exécuter des lots de requêtes simultanément en python?

Question

J'utilise l'api Reddit pour augmenter certains subreddits. J'aimerais augmenter plusieurs sous-subreds simultanément, en utilisant la bibliothèque praw pour interagir avec l'api reddit.

Je veux upvote les 27 « chauds » et les messages « hausse » de/r/bookclub:

subreddit = reddit.subreddit("bookclub") 

for submission in subreddit.hot(limit=27): 
    submission.upvote() 

for submission in subreddit.rising(limit=27): 
    submission.upvote() 

Je voudrais utiliser ou async multitraitement pour le faire plus rapidement. J'ai utilisé la bibliothèque grequests pour faire tout le .upvote() à la fois, et cela fonctionne jusqu'à présent, mais je ne suis pas sûr que ce soit vraiment mieux:

subreddit = reddit.subreddit("bookclub") 

hot_upvotes = (grequests.get(submission.upvote()) for submission in subreddit.hot(limit=27)) 
grequests.map(hot_upvotes) 

rising_upvotes = (grequests.get(submission.upvote()) for submission in subreddit.rising(limit=27)) 
grequests.map(rising_upvotes) 

Les deux versions Upvote subreddit. Ce que je me demande est s'il est possible d'exécuter les portions hot_upvotes et rising_upvotes en même temps?

Answer 1

from threading import Thread 
import functools 

subreddit = reddit.subreddit("bookclub") 

def run_hot_upvotes(subreddit): 
    hot_upvotes = (grequests.get(submission.upvote()) for submission in subreddit.hot(limit=27)) 
    grequests.map(hot_upvotes) 

def run_rising_upvotes(subreddit): 
    rising_upvotes = (grequests.get(submission.upvote()) for submission in subreddit.rising(limit=27)) 
    grequests.map(rising_upvotes) 

Thread(target = functools.partial(run_rising_upvotes, subreddit)).start() 
Thread(target = functools.partial(run_hot_upvotes, subreddit)).start() 

Essayez ce qui suit pour que les deux s'exécutent en même temps, chacun dans son propre thread.