§ Parallel process

https://github.com/imguru-mooc/python_intermediate/tree/master/5.%EB%B3%91%EB%A0%AC%20%EC%B2%98%EB%A6%AC

1. Thread

• from threading import Thread
  • Thread() 는 thread 가 실행할 동작을 설정하는 코드이며 start() 시 thread 가 수행
  • thread 를 종료시키기 위해서는 flag 를 지정해주면 좋다.

from threading import Thread
import time

class CountdownTask:
    def __init__(self):
        self._running = True

    def terminate(self):
        self._running = False

    def run(self, n):
        while self._running and n > 0:
            print("T-minus", n)
            n -= 1
            time.sleep(5)

c = CountdownTask()
t = Thread(target=c.run, args=(10,))
t.start()

time.sleep(20)
print('About to terminate')
c.terminate()
t.join()
print('Terminated')

• Event() 객체 : thread 가 잘 시작되었는지 확인하고 싶을 때 혹은 thread 가 특정 지점에 도달했는지 알아야 할 경우
  • evt = Event() 라고 생성하면, 생성과 동시에 내부 값이 0 으로 초기화 된다.
  • 함수의 args 로 evt 를 주고 함수 내부에서 evt.set() 을 하면 Event 값은 1 이 됨
  • 병렬처리 하는 부분에서 evt.wait() 를 하면, 1 이 되는 순간 그 부분도 기동된다.

import time

def countdown(n, started_evt):
    print("countdown starting")
    started_evt.set() 
    while n > 0:
        print("T-minus", n)
        n -= 1
        time.sleep(5)

started_evt = Event()

print("Launching countdown")
t = Thread(target=countdown, args=(10,started_evt))
t.start()

started_evt.wait()
print("countdown is running")

• 하지만 Event 는 한 번 쓰기에는 좋지만, 주기적으로 사용하기에는 좋지 않아 → Condition() 을 사용하자 !
  • Condition 은 지속가능한 특성이 있고 자동으로 locking 되는 기능이 있다.

import threading
import time

class PeriodicTimer:
    def __init__(self, interval):
        self._interval = interval
        self._flag = 0
        self._cv = threading.Condition()

    def start(self):
        t = threading.Thread(target=self.run)
        t.daemon = True
        t.start()

    def run(self):
        while True:
            time.sleep(self._interval)
            with self._cv:
                 self._flag ^= 1
                 self._cv.notify_all()

    def wait_for_tick(self):
        with self._cv:
            last_flag = self._flag
            while last_flag == self._flag:
                self._cv.wait()

ptimer = PeriodicTimer(5)
ptimer.start()

def countdown(nticks):
    while nticks > 0:
        ptimer.wait_for_tick()
        print("T-minus", nticks)
        nticks -= 1

def countup(last):
    n = 0
    while n < last:
        ptimer.wait_for_tick()
        print("Counting", n)
        n += 1

threading.Thread(target=countdown, args=(10,)).start()
threading.Thread(target=countup, args=(5,)).start()