#encoding=utf-8
import os
import threading

from datetime import datetime
from flow_control.controller import FlowControl
from flow_control.controller import ProcessFlowControl
from threading import Thread



def work(flowcontrol):
    while True:
        if flowcontrol.get():
            print("{}--{}--{}".format(os.getpid(), threading.currentThread().ident, datetime.now()))

flow_control = FlowControl(num=1, interval=1)
Thread(target=work, args=(flow_control,)).start()
work(flow_control)