python 스 레 드 를 강제 적 으로 죽 이지 마 세 요.
python 스 레 드 를 강제 적 으로 죽 이려 고 하지 마 세 요.이것 은 서비스 디자인 에 있어 서 이성 에 맞지 않 습 니 다.다 중 스 레 드 는 작업 의 협력 과 병행 에 사 용 됩 니 다.강제 적 인 수단 으로 스 레 드 를 제거 하면 예상 치 못 한 bug 가 발생 할 확률 이 높 습 니 다. 한 가지 만 기억 하 세 요.잠 금 자원 은 스 레 드 가 종료 되 었 기 때문에 잠 금 자원 을 방출 하지 않 습 니 다!
우 리 는 두 가지 흔히 볼 수 있 는 예 를 들 수 있다.
1.A 라인 이 자 물 쇠 를 가 져 왔 습 니 다.그 는 강제 적 으로 제거 되 었 기 때문에 제때에 release()에서 자 물 쇠 를 방출 하지 못 했 습 니 다.그러면 모든 라인 이 자원 을 가 져 오 는 것 이 막 혔 습 니 다.이것 이 바로 전형 적 인 자물쇠 장면 입 니 다.
2.흔히 볼 수 있 는 생산 소비자 의 장면 에서 소비 자 는 미 션 대기 열 에서 임 무 를 얻 지만 해 킹 당 한 후에 하고 있 는 임 무 를 대기 열 에 잃 어 버 리 지 않 으 면 데이터 가 손실 된다.
다음은 자바 와 python 이 스 레 드 를 종료 하 는 방법 입 니 다.
자바 는 스 레 드 를 종료 할 수 있 는 세 가지 방법 이 있 습 니 다.
1.종료 표 지 를 사용 하여 스 레 드 를 정상적으로 종료 합 니 다.즉,run 방법 이 완 료 된 후에 스 레 드 가 종 료 됩 니 다.
2.stop 방법 을 사용 하여 스 레 드 를 강제로 종료 합 니 다(사용 을 추천 하지 않 습 니 다.stop 은 suspend,resume 과 마찬가지 로 예측 할 수 없 는 결과 가 발생 할 수 있 기 때 문 입 니 다).
3.interrupt 방법 으로 스 레 드 를 중단 합 니 다.
python 은 두 가지 방법 이 있 습 니 다.
1.태그 끝내기
2.ctypes 를 사용 하여 스 레 드 를 강제로 죽 입 니 다.
python 이 든 자바 환경 이 든 이상 적 인 스 레 드 종료 방법 은 스 레 드 를 스스로 자살 시 키 는 것 입 니 다.스 레 드 자살 이란 바로 당신 이 그 에 게 표지 판 을 주 는 것 입 니 다.그 는 스 레 드 에서 물 러 납 니 다.
다음은 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 -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
신호 처 리 를 추가 하면 프로 세 스 를 종료 하지 않 습 니 다.
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)
python 의 스 레 드 는 시 뮬 레이 션 이 아니 라 실제 커 널 스 레 드 입 니 다.커 널 은 pthread 방법 을 호출 하지만 Python 상층 부 는 스 레 드 를 닫 는 방법 을 제공 하지 않 았 습 니 다.이것 은 우리 가 스스로 파악 해 야 합 니 다.이벤트 나 사용자 정의 플래그 위 치 를 사용 하 는 방법 을 강력 히 추천 합 니 다.스 레 드 를 강제로 죽 이려 면 python ctypes PyThreadState SetAsyncExc 방법 으로 강제 종료 할 수 있 습 니 다.이 는 실행 중인 python 서비스 에 영향 을 주지 않 습 니 다.
이 함수 의 실현 원 리 는 비교적 간단 하 다.사실은 python 가상 컴퓨터 에서 표시 위 치 를 만 든 다음 에 가상 컴퓨터 에서 이상 을 실행 하여 스 레 드 를 취소 하고 가상 기 회 는 try cache 를 잘 만들어 준다.외부 에서 python 의 한 스 레 드 를 죽 이지 마 세 요.ctypes 를 통 해 스 레 드 id 를 찾 을 수 있 지만 직접 kill 하면 전체 프로 세 스 를 처리 할 수 있 습 니 다.
아래 코드 는 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")
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;
}
이 논리 와 유사 합 니 다:
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
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 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에 따라 라이센스가 부여됩니다.
좋은 웹페이지 즐겨찾기
