[Python] Thread에서 Queue 갖고 처리하기 (2.7)

Queue 클래스는 스레드끼리 정보를 교환해야 하는 

멀티 스레드 프로그래밍 상황에서 유용하다고 문서 페이지에서도 나타내고 있다.

예전같으면(C++로 작성했다면) 뮤택스랑 세마포어, 큐가지고 했을 작업을 

파이썬에서는 Queue 클래스를 갖고 처리할 수 있다.

Queue 클래스의 멤버 함수를 일일이 열거할 생각은 없고

청하갤과 Slack 봇을 만들면서 작성했던 간단한 구조를 적어두려고 한다.

필요에 따라서 문서 페이지를 참고 하도록 하자.

동작은 아래의 소스와 주석을 참고하면 되는데

 

- 5 line : Catcher 클래스는 스레드로 동작하기 위해 threading.Thread를 상속한다.

- 8 line : 출력에서 thread 구분을 위해서 사용하는 변수

- 11~12 line : Queue에 쌓인 데이터를 모두 처리할때 까지 동작하는 While True 무한 루프.

- 13 line : Queue에서 데이터를 get 한다. 만약 Queue에 데이터가 없으면 블럭(Block)된다. 

(get 함수의 매개변수에 따라 동작은 변경할 수 있다. default로 block = True, timeout = None으로 되어 있을 뿐)

- 17 line : Queue 에다가 get 된 데이터가 모두 처리 되었다고 알린다.

내부적으로 처리되지 않은 작업의 카운터를 감소한다.

- main() 함수 : Queue를 만들고 스레드를 만들고 데이터를 put 한다음에 스레드를 시작.

- 37 line : Queue 의 모든 데이터가 처리 될 때까지 블럭 된다. 

Queue의 put 함수가 불릴때면 처리할 작업 카운터는 증가하고 task_done 함수가 불릴때면 처리할 작업 카운트가 감소한다. 

작업 카운터가 0가 되면(할일이 없으면) 이 블럭은 해제된다.