Python 스레드를 강제로 종료하지 마십시오.

머리말:

강제로 Python 스레드를 죽이려고 하지 마십시오. 이는 서비스 설계 측면에서 불합리합니다. 멀티스레딩은 작업의 공동 동시성을 위해 사용됩니다. 강제로 스레드를 종료하면 예상치 못한 버그가 발생할 가능성이 높습니다. 스레드가 종료되기 때문에 잠금 리소스가 해제되지 않는다는 점을 기억하세요!

두 가지 일반적인 예를 들 수 있습니다.

1. 스레드 A가 강제로 종료되고 release() 시간에 맞춰 잠금 리소스를 해제하지 못했기 때문에 잠금을 얻었습니다. 일반적인 교착 상태 시나리오인 리소스 획득이 차단되었습니다.

2. 일반적인 프로덕션-소비자 시나리오에서 소비자는 작업 대기열에서 작업을 가져오지만 진행 중인 작업을 종료한 후 다시 대기열에 넣지 않아 데이터가 손실됩니다.

Java와 Python에서 스레드를 종료하는 방법은 다음과 같습니다.

Java에는 스레드를 종료하는 세 가지 방법이 있습니다.

1. 스레드가 정상적으로 종료되도록 하는 종료 플래그입니다. 즉, run 메소드가 완료되면 스레드가 종료됩니다.
2. 스레드를 강제로 종료하려면 stop 메소드를 사용하십시오. (중지는 일시중단 및 재개와 동일하며 예측할 수 없는 결과가 발생할 수 있으므로 권장하지 않습니다.)
3. 스레드를 중단하려면 인터럽트 메서드를 사용하세요.

Python에는 두 가지 방법이 있습니다.

1. 종료 표시
2. ctypes를 사용하여 스레드를 강제로 종료합니다. 문제 Python 또는 Java 환경에서 스레드를 중지하고 종료하는 이상적인 방법은 스레드가 자살하도록 하는 것입니다. 소위 스레드 자살은 스레드에 플래그를 지정하고 스레드를 종료하는 것을 의미합니다.

아래에서는 Python 스레드가 중지되는 비정상적인 상황을 테스트하기 위해 다양한 방법을 사용합니다. 프로세스의 모든 실행 스레드를 살펴봅니다. 프로세스는 제어 리소스를 사용하며 스레드는 실행을 예약하려면 기본 스레드가 pid와 동일해야 합니다. 과정.

ps -mp 31449 -o THREAD,tid
 
USER   %CPU PRI SCNT WCHAN USER SYSTEM  TID
root   0.0  -  - -     -   -   -
root   0.0 19  - poll_s  -   - 31449
root   0.0 19  - poll_s  -   - 31450

프로세스의 모든 스레드를 얻은 후 strace를 통해 우리가 종료해야 하는 스레드 ID가 31450이라는 것을 알 수 있습니다. 프로세스가 모두 충돌합니다. 멀티 스레드 환경에서는 생성된 신호가 전체 프로세스에 전달됩니다. 일반적으로 모든 스레드는 이 신호를 수신할 수 있는 기회를 갖습니다. 프로세스는 신호를 수신하는 스레드 컨텍스트에서 신호 처리 기능을 실행합니다. 알기 어렵습니다. 즉, 신호는 프로세스의 스레드에 무작위로 전송됩니다.

strace -p <span style="font-size:14px;line-height:21px;">31450</span> Process <span style="font-size:14px;line-height:21px;">31450</span> attached - interrupt to quit
select(0, NULL, NULL, NULL, {0, 320326}) = 0 (Timeout)
select(0, NULL, NULL, NULL, {1, 0})   = 0 (Timeout)
select(0, NULL, NULL, NULL, {1, 0})   = 0 (Timeout)
select(0, NULL, NULL, NULL, {1, 0})   = ? ERESTARTNOHAND (To be restarted)
--- SIGTERM (Terminated) @ 0 (0) ---
Process <span style="font-size:14px;line-height:21px;">31450</span> detached

위 문제는 실제로 pthread의 설명과 일치합니다. Python 코드에 신호 처리 기능을 추가하면 콜백 기능이 전체 프로세스를 종료하지 못하게 할 수 있습니다. 그러면 신호 기능이 어떤 스레드를 종료할지 식별할 수 없습니다. 특정 스레드. 31450 스레드 ID로 신호를 보내더라도 신호 수용자는 그것이 속한 프로세스 중 하나입니다. 또한 신호 처리 기능에 전달되는 매개 변수는 선택 사항인 신호 번호와 신호 스택뿐입니다.

신호 처리를 추가한 후 프로세스가 종료되지 않습니다.

select(0, NULL, NULL, NULL, {1, 0})   = 0 (Timeout)
select(0, NULL, NULL, NULL, {1, 0})   = ? ERESTARTNOHAND (To be restarted)
--- SIGTERM (Terminated) @ 0 (0) ---
rt_sigreturn(0xffffffff)        = -1 EINTR (Interrupted system call)
select(0, NULL, NULL, NULL, {1, 0})   = 0 (Timeout)
select(0, NULL, NULL, NULL, {1, 0})   = 0 (Timeout)

외부 알림에서 스레드를 종료하려면, 그런 다음 rpc 서비스를 구축하고 사용할 수 있거나 다른 방식으로 통신할 수 있지만 신호는 더 많은 정보를 전송할 수 없기 때문에 그렇게 할 수 없습니다.

Python 스레드는 시뮬레이션되지 않고 실제 커널 스레드입니다. 커널은 pthread 메서드를 호출하지만 Python의 상위 계층에서는 스레드를 닫는 메서드를 제공하지 않으므로 직접 파악해야 합니다. 이벤트 또는 사용자 정의 플래그 비트 메서드를 사용하는 것이 좋습니다. 스레드를 강제로 종료해야 하는 경우 python ctypes PyThreadState SetAsyncExc 메서드를 사용하여 강제 종료할 수 있습니다. 이는 실행 중인 Python 서비스에 영향을 주지 않습니다.

이 함수의 구현 원리는 비교적 간단합니다. 실제로 Python 가상 머신에 플래그를 설정하면 가상 머신이 예외를 실행하여 스레드를 취소합니다. 기계가 시도 캐시를 만드는 데 도움이 될 것입니다. Python에서 외부적으로 스레드를 종료하지 마십시오. ctypes를 통해 스레드 ID를 찾을 수 있지만 직접 종료하면 전체 프로세스가 종료됩니다.

다음 코드는 스레드를 종료하기 위해 ctypes를 사용하는 예입니다.

import ctypes
 
def terminate_thread(thread):
  if not thread.isAlive():
    return
 
  exc = ctypes.py_object(SystemExit)
  res = ctypes.pythonapi.PyThreadState_SetAsyncExc(
    ctypes.c_long(thread.ident), exc)
  if res == 0:
    raise ValueError("nonexistent thread id")
  elif res > 1:
    ctypes.pythonapi.PyThreadState_SetAsyncExc(thread.ident, None)
    raise SystemError("PyThreadState_SetAsyncExc failed")

PyThreadState 소스 코드를 간단히 살펴보겠습니다. 즉, 트리거 스레드의 예외 모드가 트리거됩니다. 관심 있는 사람은 python pystate.c의 디자인을 읽고 YouTube의 일부 동영상과 공유할 수 있습니다.

 int
PyThreadState_SetAsyncExc(long id, PyObject *exc) {
  PyInterpreterState *interp = GET_INTERP_STATE();
  ...
  HEAD_LOCK();
  for (p = interp->tstate_head; p != NULL; p = p->next) {
    if (p->thread_id == id) {
      从链表里找到线程的id，避免死锁，我们需要释放head_mutex。
      PyObject *old_exc = p->async_exc;
      Py_XINCREF(exc); #增加该对象的引用数
      p->async_exc = exc; # 更为exc模式
      HEAD_UNLOCK();
      Py_XDECREF(old_exc); # 因为要取消，当然也就递减引用
      ...
      return 1; #销毁线程成功
    }
  }
  HEAD_UNLOCK();
  return 0;
}

네이티브 posix pthread는 ptread_cancel(tid)를 사용하여 기본 스레드의 하위 스레드를 종료할 수 있습니다. 그러나 Python의 스레드 라이브러리는 이를 지원하지 않습니다. 그 이유는 스레드를 강제로 종료해서는 안 되며, 이로 인해 많은 숨겨진 위험이 발생하고 스레드가 자체적으로 종료되도록 허용해야 하기 때문입니다. 따라서 Python에서 권장되는 방법은 하위 스레드를 반복하여 플래그를 결정하고, 메인 스레드에서 플래그를 변경하고, 하위 스레드가 플래그 변경을 읽을 때 스스로 종료하는 것입니다.

이 논리와 유사:

def consumer_threading():
 t1_stop= threading.Event()
 t1 = threading.Thread(target=thread1, args=(1, t1_stop))
 
 t2_stop = threading.Event()
 t2 = threading.Thread(target=thread2, args=(2, t2_stop))
 
 time.sleep(duration)
 #stop the thread2
 t2_stop.set()
 
def thread1(arg1, stop_event):
 while(not stop_event.is_set()):
   #similar to time.sleep()
   stop_event.wait(time)
   pass
 
 
def thread2(arg1, stop_event):
 while(not stop_event.is_set()):
   stop_event.wait(time)
   pass

간단히 요약하자면, ctypes에서 pystats를 사용하여 스레드를 제어할 수 있지만 스레드를 무례하게 중단하는 이 방법은 불합리합니다. 자살모드를 이용해주세요! 스레드가 io를 차단하고 이벤트를 확인할 수 없으면 어떻게 되나요? 지속적인 차단을 방지하려면 최소한 네트워크 IO 계층에서 활성 시간 제한이 있어야 합니다.

파이썬 스레드를 종료하기 위해 강제 방법을 사용하지 않는 것과 관련된 더 많은 기사를 보려면 PHP 중국어 웹사이트에 주목하세요!