# encoding=utf-8
import os
import threading

from datetime import datetime
from flow_control.controller import FlowController
from flow_control.controller import ProcessFlowController
from flow_control.controller import AverageFlowControl
from flow_control.controller import AverageProcessFlowControl
from threading import Thread



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

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