Python에서 스레드 풀 map() 메서드를 사용하여 다중 매개변수 목록을 전달하는 방법

WBOY
풀어 주다: 2023-04-29 16:25:07
앞으로
1635명이 탐색했습니다.

스레드 풀 map() 메소드는 다중 매개변수 목록을 전달합니다

이전에는 인터페이스의 다중 스레드 동시성을 촉진하기 위해 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[&#39;data&#39;][&#39;userInfo&#39;][&#39;helpedCount&#39;]}次")
로그인 후 복사

더 나은 느낌을 위해 두 인터페이스의 메서드를 살펴보겠습니다

첫 번째는 로그인 상태 가져오기 add_ticket

    def add_ticket(self, uid):
        """
        获取单独用户t票
        :param uid: 单独用户uid
        :return:
        """
        self.data[&#39;url&#39;] = ApiAddress().get_ticket
        self.data[&#39;host&#39;] = ApiAddress().host
        self.params[&#39;uid&#39;] = str(uid)
        self.params[&#39;type&#39;] = 0
        self.data[&#39;params&#39;] = json.dumps(self.params)
        res = r().post(url=ApiAddress().ticket, data=self.data)
        print(f&#39;获取t票结果:{uid}{res}&#39;)
        return uid
로그인 후 복사

매우 간단한 인터페이스 요청에는 uid 매개변수가 하나만 있지만 주의하세요. 여기의 uid는 목록이 아니라 단지 매개변수일 뿐입니다.

map()에 전달된 메소드 매개변수는 UID 콘텐츠 목록인 질문이 있는 학생들이 있습니다.

map() 메소드는 필요한 매개변수를 목록에 저장하고 순회를 통해 지정한 인터페이스를 요청하는 것입니다.

이 시점에서 어떤 분들은 이렇게 물으실 수도 있습니다. 제가 당시에도 같은 질문을 했기 때문에 한 메서드에 여러 개의 매개변수가 있고 이들 매개변수 중 일부는 고정된 내용도 아닌 경우 어떻게 될까요?

도움말 인터페이스를 요청하는 또 다른 방법을 살펴보겠습니다

    def help(self, agrs):
        """
        助力用户
        :param agrs: uid:当前用户uid to_uid:助力用户uid count:助力次数
        :return:
        """
        uid, to_uid, count = agrs
        self.attrs[&#39;toUid&#39;] = str(to_uid)
        self.attrs[&#39;count&#39;] = count
        response = r().response(uid, self.code, "help", **self.attrs)
        logger.info(f&#39;help response uid:{uid} to_uid:{to_uid}\n{response}&#39;)
        return response
로그인 후 복사

예, 튜플을 통해 도움말 인터페이스에 전달하고, 튜플의 키워드 위치를 통해 지정된 요소에 값을 할당합니다.

스레드 풀의 코드에서는 목록 파생을 사용하여 uid_list의 매개변수를 사용자가 지정한 튜플로 쉽게 만듭니다. 물론 여기에 매개변수가 여러 개 있는 경우 사전을 사용할 수도 있으며 사전을 사용하여 키를 쉽게 만들 수도 있습니다. 매개변수 변경. 목록 이해가 목록을 반환하므로 필요한 매개변수를 튜플에 넣고 튜플을 목록에 배치하여 다중 매개변수 메서드에 대해 map() 스레드 풀을 사용할 수 있습니다. 동시성을 위해.

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() 메서드를 사용하여 다중 매개변수 목록을 전달하는 방법리스트 컴프리헨션을 얻은 후에는 아마도 아래의 리스트 데이터 내용 형식일 것입니다🎜🎜🎜

위 내용은 Python에서 스레드 풀 map() 메서드를 사용하여 다중 매개변수 목록을 전달하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

관련 라벨:
원천:yisu.com
본 웹사이트의 성명
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.
인기 튜토리얼
더>
최신 다운로드
더>
웹 효과
웹사이트 소스 코드
웹사이트 자료
프론트엔드 템플릿