mtsleppB.py 文件源码

def main():
    print('starting --',ctime())
    locks = []
    nloops = range(len(loops))

    for i in nloops:
        lock = _thread.allocate_lock() # ?????
        lock.acquire() # ?????
        locks.append(lock)

    for  i in nloops:
        _thread.start_new_thread(loop,(i,loops[i],locks[i]))

    for i in nloops:
        while locks[i].locked():
            pass

    print('all Done---',ctime())