Commit cb8e5b06 authored by 桂秋月's avatar 桂秋月

增加了多线程处理

parent f647573c
/search/tempFile/*
/feature/tempFile/*
/recommend/tempFile/*
/tools/changeLXQpassword.py
\ No newline at end of file
/tools/changeLXQpassword.py
/tools/temp.py
\ No newline at end of file
......@@ -140,7 +140,8 @@ def bingji(a,b):
if __name__ == '__main__':
a=[1,2,4,3,5,6,7,8,9,10]
b=[10,2,4]
print(split_by_num(b,3))
print(split_by_num(a,3))
print(split_by_length(b,1))
#print(int(11/2))
#a=[[1,2],[2,3]]
......
import math
import threading,time
from tools.listOperation import *
......@@ -26,28 +27,37 @@ class MyThread(threading.Thread):
#print(self.name,'-->multhread:',self.result)
return self.result
def main(thnum):
num=list(range(100))
#thnum=5
divnum=int(len(num)/thnum)
divlists=split_by_length(num,divnum)
#print(divlists)
temp=[]
def tttt(ldata,kwargs={}):
print('1==',ldata)
print('2==',kwargs)
flag1=kwargs.get('init_data') or 0
for i in ldata:
return i+flag1
def main(thnum,list_data,func,**kwargs):
divlists=split_by_num(list_data,thnum)
temp_threads=[]
mult_thread_result=[]
for i in range(thnum):
t=MyThread(func,divlists[i])
temp.append(t)
t=MyThread(func,divlists[i],**kwargs)
temp_threads.append(t)
t.start()
for i in temp:
for i in temp_threads:
i.join()
for i in temp_threads:
mult_thread_result.append(i.get_result())
return mult_thread_result
if __name__ == '__main__':
flag={"init_data":10}
list_data=[i for i in range(100)]
t=time.time()
main(5)
result=main(5,list_data,tttt,**flag)
tt=time.time()
print(tt-t)
print('final',result)
# print("=="*50)
# t=time.time()
# for i in list(range(100)):
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment