import threading import sys import time g_cnt = 0 def deal_data(): print("deal_data") sys.stdout.flush() i = 1 global g_cnt g_cnt+=1 tmpcnt = g_cnt ccc = 0 betm = time.time() while(True): i = i/(i+1) i = i*2 if(i<1): i= 2 ccc+=1 entm = time.time()-betm if(entm > 10): print("cnt",tmpcnt,ccc) ccc=0 betm = time.time() #if(ccc%10000==1): # print(tmpcnt) # sys.stdout.flush() t = None for i in range(4): t = threading.Thread(target=deal_data) t.start() #t.join() print("over..................") while(True): print("111over..................") time.sleep(5)