Python 스레드의 일시 중지, 재개 및 종료 예제 코드에 대한 자세한 설명

Python 스레드 일시 중지, 재개, 종료

Python의 스레딩 모듈이 멀티 스레딩을 구현할 수 있다는 것은 모두 알고 있지만 모듈은 일시 중지를 제공하지 않습니다. , 재개 및 스레드를 중지하려면 스레드 개체가 시작 메서드를 호출하면 해당 메서드 함수가 완료될 때까지만 기다릴 수 있습니다. 즉, 일단 시작된 스레드는 제어할 수 없습니다. 일반적인 방법은 루프 플래그 비트를 결정하고 플래그 비트가 미리 정해진 값에 도달하면 루프를 종료하는 것입니다. 이렇게 하면 스레드를 종료할 수 있지만 스레드를 일시 중지하고 다시 시작하는 것이 약간 어렵습니다. 스레딩에서 Event 개체의 wait 메서드에 대한 설명을 보면

wait([timeout])

  Block until the internal flag is true. If the internal flag is true on entry, return immediately. Otherwise, block until another thread calls set() to set the flag to true, or until the optional timeout occurs.

  阻塞, 直到内部的标志位为True时. 如果在内部的标志位在进入时为True时, 立即返回. 否则, 阻塞直到其他线程调用set()方法将标准位设为True, 或者到达了可选的timeout时间.

  When the timeout argument is present and not None, it should be a floating point number specifying a timeout for the operation in seconds (or fractions thereof).

  This method returns the internal flag on exit, so it will always return True except if a timeout is given and the operation times out.

  当给定了timeout参数且不为None, 它应该是一个浮点数，以秒为单位指定操作的超时（或是分数）。

  此方法在退出时返回内部标志，因此除非给定了超时且操作超时，否则它将始终返回True。

  Changed in version 2.7: Previously, the method always returned None.

  2.7版本以前, 这个方法总会返回None.

wait라는 차단 메커니즘을 사용하는 경우 일시 중지 및 복구를 달성한 다음 루프 판단 플래그 비트에 협력하면 종료할 수 있습니다.

#!/usr/bin/env python
# coding: utf-8

import threading
import time

class Job(threading.Thread):

  def __init__(self, *args, **kwargs):
    super(Job, self).__init__(*args, **kwargs)
    self.__flag = threading.Event()   # 用于暂停线程的标识
    self.__flag.set()    # 设置为True
    self.__running = threading.Event()   # 用于停止线程的标识
    self.__running.set()   # 将running设置为True

  def run(self):
    while self.__running.isSet():
      self.__flag.wait()   # 为True时立即返回, 为False时阻塞直到内部的标识位为True后返回
      print time.time()
      time.sleep(1)

  def pause(self):
    self.__flag.clear()   # 设置为False, 让线程阻塞

  def resume(self):
    self.__flag.set()  # 设置为True, 让线程停止阻塞

  def stop(self):
    self.__flag.set()    # 将线程从暂停状态恢复, 如何已经暂停的话
    self.__running.clear()    # 设置为False

다음은 테스트 코드입니다. 🎜>

a = Job()
a.start()
time.sleep(3)
a.pause()
time.sleep(3)
a.resume()
time.sleep(3)
a.pause()
time.sleep(2)
a.stop()

테스트 결과:




이렇게 하면 일시 중지, 재개 및 중지 기능이 완성됩니다. 여기서 단점은 일시 중지나 중지가 즉시 이루어지지 않는다는 점입니다. 즉, 실행 기능 내에서 작업이 실행되기 전에 플래그 비트 판단에 도달할 때까지 기다려야 합니다.

하지만. 이는 때때로 반드시 나쁜 것은 아닙니다. 실행 함수에 파일 작업이나 데이터베이스 작업이 포함된 경우 잠깐, 완전히 한 번 실행한 다음 종료합니다. 대신 나머지 리소스 해제 작업(예: 다양한 닫기)에 대한 코드를 실행할 수 있습니다. 프로그램의 파일 연산자가 상한을 초과하거나 데이터베이스 연결이 해제되지 않는 등 당황스러운 상황은 발생하지 않습니다.

읽어 주셔서 감사합니다. 도움이 되었으면 좋겠습니다. 이 사이트를 지원해 주셔서 감사합니다!

위 내용은 Python 스레드의 일시 중지, 재개 및 종료 예제 코드에 대한 자세한 설명의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!