이전에는 인터페이스의 다중 스레드 동시성을 촉진하기 위해 threading.thread()가 사용되었지만 동시성 수가 적을 때 더 유용합니다. 동시성이 큰 스레드 패키지 외에 코루틴 처리의 경우 스레드 풀 방식을 사용할 수도 있습니다.
평신도의 관점에서 스레드 풀의 구현은 모든 작업을 메시지 대기열에 넣고 여러 스레드를 시작한 다음 스레드를 실행하는 것입니다. 그러나 스레드 실행이 완료된 후에는 스레드 작업이 중단되지 않으며 스레드 실행을 위해 메시지 큐에서 스레드 작업을 계속 가져오므로 스레드 풀은 다중 스레드 작업에 비해 스레드를 생성하고 닫는 많은 단계를 줄여 대부분의 리소스와 시간을 절약합니다.
import concurrent.futures
ThreadPoolExecutor가 필요합니다. 두 가지 스레드 풀 메소드인 map()과 submit()이 있습니다. 오늘은 map() 메소드에 대해 이야기하겠습니다.
with concurrent.futures.ThreadPoolExecutor() as pool: res = pool.map(craw, uid_list) print(res)
< code>map() 내부 크롤링은 메소드 이름입니다. 여기서 메소드 이름은 ()map()
内craw为方法名,这里方法命不带()
uid_list
uid_list
가 메소드 매개변수입니다. map() 메서드에 전달되었습니다먼저 살펴보겠습니다. 전체 코드5000 사용자 동시성 지원def test_case_09(self): """5000用户并发助力""" # 通过yaml配置文件封装方法 获取uid_list uid_list = YamlHandler(YamlThePath().number_new).get_uid_list() # add_ticket获取5000账号登陆状态 with concurrent.futures.ThreadPoolExecutor() as pool: pool.map(AccountAccess().add_ticket, uid_list) # 5000账号线程池方法助力用户 with concurrent.futures.ThreadPoolExecutor() as pool: pool.map(PreheatMethod().help, [(uid, self.A, 1) for uid in uid_list]) # 获取用户被助力次数 response = PreheatMethod().init(self.A) print(f"当前用户被助力次数 :{response['data']['userInfo']['helpedCount']}次")
def add_ticket(self, uid): """ 获取单独用户t票 :param uid: 单独用户uid :return: """ self.data['url'] = ApiAddress().get_ticket self.data['host'] = ApiAddress().host self.params['uid'] = str(uid) self.params['type'] = 0 self.data['params'] = json.dumps(self.params) res = r().post(url=ApiAddress().ticket, data=self.data) print(f'获取t票结果:{uid}{res}') return uid
def help(self, agrs): """ 助力用户 :param agrs: uid:当前用户uid to_uid:助力用户uid count:助力次数 :return: """ uid, to_uid, count = agrs self.attrs['toUid'] = str(to_uid) self.attrs['count'] = count response = r().response(uid, self.code, "help", **self.attrs) logger.info(f'help response uid:{uid} to_uid:{to_uid}\n{response}') return response
with concurrent.futures.ThreadPoolExecutor() as pool: pool.map(PreheatMethod().help, [(uid, self.A, 1) for uid in uid_list])
[(uid, self.A, 1) for uid in uid_list]
위 내용은 Python에서 스레드 풀 map() 메서드를 사용하여 다중 매개변수 목록을 전달하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!