python에서threading과queue 라이브러리로 다중 프로그래밍 실현
요약
본고는 주로python의threading과queue 라이브러리를 이용하여 다중 루틴 프로그래밍을 실현하고 하나의 클래스로 봉인하여 독자가 자신의 업무 논리에 끼워 넣기 편리하도록 소개한다.마지막으로 기계 학습의 초변수 선택을 예로 들어 보여 준다.
다중 스레드 논리 봉인 실현
이 종류를 실례화한 후에.object_func 함수에 자신의 업무 논리를 넣고 호출합니다.run 방법이면 됩니다.
# -*- coding: utf-8 -*-
# @Time : 2021/2/4 14:36
# @Author : CyrusMay WJ
# @FileName: run.py
# @Software: PyCharm
# @Blog :https://blog.csdn.net/Cyrus_May
import queue
import threading
class CyrusThread(object):
def __init__(self,num_thread = 10,logger=None):
"""
:param num_thread:
:param logger:
"""
self.num_thread = num_thread
self.logger = logger
def object_func(self,args_queue,max_q):
while 1:
try:
arg = args_queue.get_nowait()
step = args_queue.qsize()
self.logger.info("progress:{}\{}".format(max_q,step))
except:
self.logger.info("no more arg for args_queue!")
break
"""
"""
def run(self,args):
args_queue = queue.Queue()
for value in args:
args_queue.put(value)
threads = []
for i in range(self.num_thread):
threads.append(threading.Thread(target=self.object_func,args = args_queue))
for t in threads:
t.start()
for t in threads:
t.join()
모델 매개변수 선택 인스턴스
# -*- coding: utf-8 -*-
# @Time : 2021/2/4 14:36
# @Author : CyrusMay WJ
# @FileName: run.py
# @Software: PyCharm
# @Blog :https://blog.csdn.net/Cyrus_May
import queue
import threading
import numpy as np
from sklearn.datasets import load_boston
from sklearn.svm import SVR
import logging
import sys
class CyrusThread(object):
def __init__(self,num_thread = 10,logger=None):
"""
:param num_thread:
:param logger:
"""
self.num_thread = num_thread
self.logger = logger
def object_func(self,args_queue,max_q):
while 1:
try:
arg = args_queue.get_nowait()
step = args_queue.qsize()
self.logger.info("progress:{}\{}".format(max_q,max_q-step))
except:
self.logger.info("no more arg for args_queue!")
break
#
C, epsilon, gamma = arg[0], arg[1], arg[2]
svr_model = SVR(C=C, epsilon=epsilon, gamma=gamma)
x, y = load_boston()["data"], load_boston()["target"]
svr_model.fit(x, y)
self.logger.info("score:{}".format(svr_model.score(x,y)))
def run(self,args):
args_queue = queue.Queue()
max_q = 0
for value in args:
args_queue.put(value)
max_q += 1
threads = []
for i in range(self.num_thread):
threads.append(threading.Thread(target=self.object_func,args = (args_queue,max_q)))
for t in threads:
t.start()
for t in threads:
t.join()
#
logger = logging.getLogger()
logger.setLevel(logging.INFO)
screen_handler = logging.StreamHandler(sys.stdout)
screen_handler.setLevel(logging.INFO)
formatter = logging.Formatter('%(asctime)s - %(module)s.%(funcName)s:%(lineno)d - %(levelname)s - %(message)s')
screen_handler.setFormatter(formatter)
logger.addHandler(screen_handler)
#
args = []
for C in [i for i in np.arange(0.01,1,0.01)]:
for epsilon in [i for i in np.arange(0.001,1,0.01)] + [i for i in range(1,10,1)]:
for gamma in [i for i in np.arange(0.001,1,0.01)] + [i for i in range(1,10,1)]:
args.append([C,epsilon,gamma])
#
threading_tool = CyrusThread(num_thread=20,logger=logger)
threading_tool.run(args)
실행 결과2021-02-04 20:52:22,824 - run.object_func:31 - INFO - progress:1176219\1
2021-02-04 20:52:22,824 - run.object_func:31 - INFO - progress:1176219\2
2021-02-04 20:52:22,826 - run.object_func:31 - INFO - progress:1176219\3
2021-02-04 20:52:22,833 - run.object_func:31 - INFO - progress:1176219\4
2021-02-04 20:52:22,837 - run.object_func:31 - INFO - progress:1176219\5
2021-02-04 20:52:22,838 - run.object_func:31 - INFO - progress:1176219\6
2021-02-04 20:52:22,841 - run.object_func:31 - INFO - progress:1176219\7
2021-02-04 20:52:22,862 - run.object_func:31 - INFO - progress:1176219\8
2021-02-04 20:52:22,873 - run.object_func:31 - INFO - progress:1176219\9
2021-02-04 20:52:22,884 - run.object_func:31 - INFO - progress:1176219\10
2021-02-04 20:52:22,885 - run.object_func:31 - INFO - progress:1176219\11
2021-02-04 20:52:22,897 - run.object_func:31 - INFO - progress:1176219\12
2021-02-04 20:52:22,900 - run.object_func:31 - INFO - progress:1176219\13
2021-02-04 20:52:22,904 - run.object_func:31 - INFO - progress:1176219\14
2021-02-04 20:52:22,912 - run.object_func:31 - INFO - progress:1176219\15
2021-02-04 20:52:22,920 - run.object_func:31 - INFO - progress:1176219\16
2021-02-04 20:52:22,920 - run.object_func:39 - INFO - score:-0.01674283914287855
2021-02-04 20:52:22,929 - run.object_func:31 - INFO - progress:1176219\17
2021-02-04 20:52:22,932 - run.object_func:39 - INFO - score:-0.007992354170952565
2021-02-04 20:52:22,932 - run.object_func:31 - INFO - progress:1176219\18
2021-02-04 20:52:22,945 - run.object_func:31 - INFO - progress:1176219\19
2021-02-04 20:52:22,954 - run.object_func:31 - INFO - progress:1176219\20
2021-02-04 20:52:22,978 - run.object_func:31 - INFO - progress:1176219\21
2021-02-04 20:52:22,984 - run.object_func:39 - INFO - score:-0.018769934807246536
2021-02-04 20:52:22,985 - run.object_func:31 - INFO - progress:1176219\22
이는python에서threading과queue 라이브러리에서 다중 루틴 프로그래밍을 실현하는 것에 관한 이 글을 소개합니다. 더 많은python 다중 루틴 프로그래밍 내용은 이전의 글을 검색하거나 아래의 관련 글을 계속 훑어보십시오. 앞으로 많은 응원 부탁드립니다!
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
로마 숫자를 정수로 또는 그 반대로 변환그 중 하나는 로마 숫자를 정수로 변환하는 함수를 만드는 것이었고 두 번째는 그 반대를 수행하는 함수를 만드는 것이었습니다. 문자만 포함합니다'I', 'V', 'X', 'L', 'C', 'D', 'M' ; 문자열이 ...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.