Python 스레드 정렬-파이썬 튜토리얼-php.cn

Python 스레드 정렬

巴扎黑

풀어 주다： 2016-12-09 14:11:47

원래의

1516명이 탐색했습니다.

스레드에는 5가지 상태가 있습니다.

새로 만들기, 준비됨, 실행 중, 차단됨, 종료됨.

차단에는 세 가지 상황이 있습니다.

동기 차단은 잠금을 요청할 때 경쟁하는 잠금 상태를 의미하며 스레드는 이 상태로 진입하고 실행 상태로 돌아갑니다. 잠금이 성공적으로 획득되면 대기 차단은 다른 스레드의 알림을 기다리는 상태를 의미합니다. 스레드가 조건부 잠금을 획득한 후 "wait"를 호출하면 다른 스레드가 알림을 보내면 이 상태가 됩니다. 스레드는 동기 차단 상태에 들어가 다시 조건부 잠금을 위해 경쟁합니다.

다른 차단은 time.sleep(), anotherthread.join()을 호출하거나 IO를 기다릴 때 차단되는 것을 의미합니다. 스레드는 획득한 잠금을 해제하지 않습니다.

Python은 스레드를 사용하는 두 가지 방법을 제공합니다. 하나는 함수형이고 다른 하나는 클래스 패키징입니다.

* 스레드
* 스레딩

1. 스레드:

thread.start_new_thread ( function , args [ , kwargs ] )

>>> import thread
>>> dir(thread)
[&#39;LockType&#39;, &#39;__doc__&#39;, &#39;__name__&#39;, &#39;__package__&#39;, &#39;_count&#39;, &#39;_local&#39;, &#39;allocate&#39;, &#39;allocate_lock&#39;, &#39;error&#39;, &#39;exit&#39;, &#39;exit_thread&#39;, &#39;get_ident&#39;, &#39;interrupt_main&#39;, &#39;stack_size&#39;, &#39;start_new&#39;, &#39;start_new_thread&#39;]

로그인 후 복사

스레드 호출 module 새로운 스레드를 생성하는 start_new_thread() 함수입니다.

2. Threading:

>>> import threading
>>> dir(threading)
[&#39;BoundedSemaphore&#39;, &#39;Condition&#39;, &#39;Event&#39;, &#39;Lock&#39;, &#39;RLock&#39;, &#39;Semaphore&#39;, &#39;Thread&#39;, &#39;ThreadError&#39;, &#39;Timer&#39;, &#39;_BoundedSemaphore&#39;, &#39;_Condition&#39;, &#39;_DummyThread&#39;, &#39;_Event&#39;, &#39;_MainThread&#39;, &#39;_RLock&#39;, &#39;_Semaphore&#39;, &#39;_Timer&#39;, &#39;_VERBOSE&#39;, &#39;_Verbose&#39;, &#39;__all__&#39;, &#39;__builtins__&#39;, &#39;__doc__&#39;, &#39;__file__&#39;, &#39;__name__&#39;, &#39;__package__&#39;, &#39;_active&#39;, &#39;_active_limbo_lock&#39;, &#39;_after_fork&#39;, &#39;_allocate_lock&#39;, &#39;_counter&#39;, &#39;_enumerate&#39;, &#39;_format_exc&#39;, &#39;_get_ident&#39;, &#39;_limbo&#39;, &#39;_newname&#39;, &#39;_pickSomeNonDaemonThread&#39;, &#39;_profile_hook&#39;, &#39;_shutdown&#39;, &#39;_sleep&#39;, &#39;_start_new_thread&#39;, &#39;_sys&#39;, &#39;_test&#39;, &#39;_time&#39;, &#39;_trace_hook&#39;, &#39;activeCount&#39;, &#39;active_count&#39;, &#39;currentThread&#39;, &#39;current_thread&#39;, &#39;deque&#39;, &#39;enumerate&#39;, &#39;local&#39;, &#39;setprofile&#39;, &#39;settrace&#39;, &#39;stack_size&#39;, &#39;warnings&#39;]

로그인 후 복사

threading 모듈에서 제공하는 일반적인 메서드:

>>> dir(threading.Thread)
[&#39;_Thread__bootstrap&#39;, &#39;_Thread__bootstrap_inner&#39;, &#39;_Thread__delete&#39;, &#39;_Thread__exc_clear&#39;, &#39;_Thread__exc_info&#39;, &#39;_Thread__initialized&#39;, &#39;_Thread__stop&#39;, &#39;__class__&#39;, &#39;__delattr__&#39;, &#39;__dict__&#39;, &#39;__doc__&#39;, &#39;__format__&#39;, &#39;__getattribute__&#39;, &#39;__hash__&#39;, &#39;__init__&#39;, &#39;__module__&#39;, &#39;__new__&#39;, &#39;__reduce__&#39;, &#39;__reduce_ex__&#39;, &#39;__repr__&#39;, &#39;__setattr__&#39;, &#39;__sizeof__&#39;, &#39;__str__&#39;, &#39;__subclasshook__&#39;, &#39;__weakref__&#39;, &#39;_block&#39;, &#39;_note&#39;, &#39;_reset_internal_locks&#39;, &#39;_set_daemon&#39;, &#39;_set_ident&#39;, &#39;daemon&#39;, &#39;getName&#39;, &#39;ident&#39;, &#39;isAlive&#39;, &#39;isDaemon&#39;, &#39;is_alive&#39;, &#39;join&#39;, &#39;name&#39;, &#39;run&#39;, &#39;setDaemon&#39;, &#39;setName&#39;, &#39;start&#39;]

로그인 후 복사

threading.currentThread(): 현재 스레드 변수를 반환합니다. .

threading.enumerate(): 실행 중인 스레드가 포함된 목록을 반환합니다. 실행은 시작 전과 종료 후 스레드를 제외하고 시작 후 종료 전 스레드를 나타냅니다.

threading.activeCount(): 실행 중인 스레드 수를 반환하며, 이는 len(threading.enumerate())과 동일한 결과를 갖습니다.

threading.Thread 메서드를 상속하고 run 메서드를 재정의합니다.

threading.Thread 클래스의 초기화 함수 프로토타입: def __init__(self, group=None, target=None, name=None, args=(), kwargs={})
매개변수 그룹은 예약되어 있습니다. 향후 확장을 위해
매개변수 대상은 스레드가 시작된 후 실행되는 호출 가능한 개체(활동 [활동]이라고도 함)입니다.
매개변수 이름은 스레드의 이름입니다. 기본값은 "Thread-N"입니다. 여기서 N은 숫자입니다.
매개변수 args와 kwargs는 각각 target 호출 시 매개변수 목록과 키워드 매개변수를 나타냅니다.

join() 메소드를 사용하면 이 메소드를 호출하는 스레드는 Thread 객체가 완료될 때까지 기다렸다가 실행을 재개합니다.
Thread.join을 호출하면 호출된 스레드의 실행이 완료되거나 시간 초과될 때까지 호출 스레드가 차단됩니다. 매개변수 timeout은 시간 초과 시간을 나타내는 숫자 유형입니다. 이 매개변수가 제공되지 않으면 호출 스레드는 호출된 스레드가 끝날 때까지 차단됩니다.

threading.Lock 개체: 뮤텍스, acquire() 및 release() 메서드 사용

RLock을 사용하면 동일한 스레드에서 여러 번 획득할 수 있습니다. 하지만 Lock은 이를 허용하지 않습니다. 참고: RLock을 사용하는 경우 획득과 해제는 쌍으로 나타나야 합니다. 즉, 획득이 n번 호출되고 해제가 n번 호출되어야 점유된 잠금을 실제로 해제할 수 있습니다.

threading.Condition 개체: 조건 변수. 이 개체가 생성되면 Lock 개체가 포함됩니다(조건 변수는 항상 뮤텍스와 함께 사용되기 때문). 잠재적인 Lock 객체를 제어하기 위해 Condition 객체에서 acquire() 및 release() 메서드를 호출할 수 있습니다.

Condition.wait([timeout]): 대기 메서드는 점유된 내부 메모리를 해제하고 스레드는 알림을 받은 후 깨어나거나 타임아웃될 때까지 일시 중지됩니다(타임아웃이 발생한 경우). 매개 변수는 단어로 제공됩니다). 스레드가 깨어나 스레드를 다시 점유하면 프로그램은 계속 실행됩니다.

Condition.notify(): 일시 중단된 스레드를 깨웁니다(일시 중단된 스레드가 있는 경우). 참고: inform() 메소드는 점유된 메모리를 해제하지 않습니다.

Condition.notifyAll() 일시 중단된 스레드를 모두 깨웁니다(일시 중단된 스레드가 있는 경우). 참고: 이 방법은 점유된 메모리를 해제하지 않습니다.