truncatedata.py 文件源码

def _main():
    """ Start multiple processes to truncate data out of measurements. """
    wlock = Manager().Lock()
    pool = PoolLimit()
    probes = cprobes()
    try:
        while True:
            try:
                cprobe = probes.next()
            except StopIteration:
                break
            pool.apply_async(_truncate, (cprobe, wlock))
        pool.close()
        pool.join()
    except KeyboardInterrupt:
        pass