gistfile1.txt

import threading
import time


class Event(object):
    def __init__(self):
        self._cond = threading.Condition()
        self._val = False

    def set(self):
        with self._cond:
            self._val = True
            self._cond.notify_all()

    def clear(self):
        with self._cond:
            self._val = False

    def is_set(self):
        return self._val

    def wait(self, timeout=None):
        with self._cond:
            if timeout is None:
                self._cond.wait()
                return self.is_set()
            else:
                started_at = time.time()
                while (time.time() - started_at < timeout):
                    if self.is_set():
                        break
                    else:
                        print("Still waiting...")
                        self._cond.wait(0.01)
                return self.is_set()