반응형
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가 되면(할일이 없으면) 이 블럭은 해제된다.
반응형
'python > python' 카테고리의 다른 글
| 파이썬(Python)-취미 프로그래밍, 취미 프로젝트의 시작. (2) | 2016.06.09 |
|---|