线程池多线程操作录入excelshuj

水深与云起

是这样的 我从网上找到这么一段多线程操作录入excel数据，可是不是计算机专业的，能力有限我看不懂哈哈
希望有人能帮我翻译成易语言，或者能给个线程池大批量录入excel数据的方法，感激不尽
#!/ufr/bin/env python# -*- coding:utf-8 -*-import xlwings as xwimport queueimport threadingimport timeStopEvent = object()class TreadPool:    def __init__(self, max_num, max_tast_num = 0):        self.max_num = max_num  #最大线程数        if max_tast_num:  #根据是否制定最大任务数来指定队列程度            self.q = queue.Queue()  #队列不限定长度        else:            self.q = queue.Queue(max_tast_num)  #根据用户指定长度创建队列        self.generate_list = []   #记录生成的线程        self.free_list = []   #记录空闲的线程        self.terminal = False    def run(self, target, args, callback=None):        """运行该函数，调用线程池"""        if len(self.free_list) == 0 and len(self.generate_list) < self.max_num:            #没有空闲线程并且当前创建线程数量小于最大允许线程数量时允许创建线程            self.creat_thread() #调用创建线程函数        tast = (target, args, callback)  #将任务打包成为元组放入队列        self.q.put(tast)    def creat_thread(self):        """创建线程，并且运行，这时调用call函数，所有实现均在call函数内"""        thread = threading.Thread(target=self.call)        thread.start()    def call(self):        """线程调用该函数"""        current_thread = threading.currentThread()  #获取执行该函数的当前线程        self.generate_list.append(current_thread)  #将线程加入生成的线程列表        tast = self.q.get()  #从队列中取出一个任务包        while tast != StopEvent:            target, args, backcall = tast  #将元组人物包，赋值给变量            try:                result = target(*args)  #执行函数，并将返回值赋值给result            except Exception as e:                result = None            if backcall:                try:                    backcall(result)  #执行回调函数，并将result作为参数传给回调函数                except Exception as e:                    pass            self.free_list.append(current_thread) #执行完毕，将当前线程对象加入空闲列表            if self.terminal: #是否强制终止                tast = StopEvent            else:                tast = self.q.get()  #等待那任务，如果有任务直接循环执行，如果没有则等待，一旦run方法中放入任务则继续执行任务，无需再创建线程            self.free_list.remove(current_thread) #拿到任务后，清除空闲线程        else:            self.generate_list.remove(current_thread)    def close(self):        """所有线程全部运行完毕后，停止线程        call函数运行完毕后，所有的线程此时都在等待拿任务，此时，只要给队列里面添加StopEvent对象则线程就会结束"""        generate_size = len(self.generate_list)        while generate_size:            self.q.put(StopEvent)            generate_size -= 1    def terminate(self):        """不等待线程全部运行完毕任务，直接终止"""        self.terminal = True  #正在运行的线程运行完毕后会终止        generate_size = len(self.generate_list)        while generate_size:  #终止已经在等待的那一部分线程            self.q.put(StopEvent)            generate_size -= 1def func(li):    for i in range(10000):        li.append()def world():    wb = xw.Book.caller()    li = []    pool = TreadPool(5)    for i in range(5):        pool.run(target=func, args=(li,))    pool.close()    print(li)    wb = xw.Book.caller()    wb.sheets[0].range("a1").value = li

东方优源

Excel操作 大shuj  https://bbs.125.la/forum.php?mod=viewthread&tid=14413012

看看这个能不能解决

水深与云起

排版我看着太乱了 重新放到了一个word里面

水深与云起

1. #!/ufr/bin/env python
   
2. # -*- coding:utf-8 -*-
   
3. 
   
4. import xlwings as xw
   
5. 
   
6. 
   
7. import queue
   
8. import threading
   
9. import time
   
10. StopEvent = object()
    
11. class TreadPool:
    
12.     def __init__(self, max_num, max_tast_num = 0):
    
13.         self.max_num = max_num  #最大线程数
    
14.         if max_tast_num:  #根据是否制定最大任务数来指定队列程度
    
15.             self.q = queue.Queue()  #队列不限定长度
    
16.         else:
    
17.             self.q = queue.Queue(max_tast_num)  #根据用户指定长度创建队列
    
18.         self.generate_list = []   #记录生成的线程
    
19.         self.free_list = []   #记录空闲的线程
    
20.         self.terminal = False
    
21.     def run(self, target, args, callback=None):
    
22.         """运行该函数，调用线程池"""
    
23.         if len(self.free_list) == 0 and len(self.generate_list) < self.max_num:
    
24.             #没有空闲线程并且当前创建线程数量小于最大允许线程数量时允许创建线程
    
25.             self.creat_thread() #调用创建线程函数
    
26.         tast = (target, args, callback)  #将任务打包成为元组放入队列
    
27.         self.q.put(tast)
    
28. 
    
29.     def creat_thread(self):
    
30.         """创建线程，并且运行，这时调用call函数，所有实现均在call函数内"""
    
31.         thread = threading.Thread(target=self.call)
    
32.         thread.start()
    
33.     def call(self):
    
34.         """线程调用该函数"""
    
35.         current_thread = threading.currentThread()  #获取执行该函数的当前线程
    
36.         self.generate_list.append(current_thread)  #将线程加入生成的线程列表
    
37. 
    
38.         tast = self.q.get()  #从队列中取出一个任务包
    
39. 
    
40.         while tast != StopEvent:
    
41.             target, args, backcall = tast  #将元组人物包，赋值给变量
    
42.             try:
    
43.                 result = target(*args)  #执行函数，并将返回值赋值给result
    
44.             except Exception as e:
    
45.                 result = None
    
46. 
    
47.             if backcall:
    
48.                 try:
    
49.                     backcall(result)  #执行回调函数，并将result作为参数传给回调函数
    
50.                 except Exception as e:
    
51.                     pass
    
52. 
    
53.             self.free_list.append(current_thread) #执行完毕，将当前线程对象加入空闲列表
    
54.             if self.terminal: #是否强制终止
    
55.                 tast = StopEvent
    
56.             else:
    
57.                 tast = self.q.get()  #等待那任务，如果有任务直接循环执行，如果没有则等待，一旦run方法中放入任务则继续执行任务，无需再创建线程
    
58.             self.free_list.remove(current_thread) #拿到任务后，清除空闲线程
    
59.         else:
    
60.             self.generate_list.remove(current_thread)
    
61.     def close(self):
    
62.         """所有线程全部运行完毕后，停止线程
    
63.         call函数运行完毕后，所有的线程此时都在等待拿任务，此时，只要给队列里面添加StopEvent对象则线程就会结束"""
    
64.         generate_size = len(self.generate_list)
    
65.         while generate_size:
    
66.             self.q.put(StopEvent)
    
67.             generate_size -= 1
    
68.     def terminate(self):
    
69.         """不等待线程全部运行完毕任务，直接终止"""
    
70.         self.terminal = True  #正在运行的线程运行完毕后会终止
    
71.         generate_size = len(self.generate_list)
    
72.         while generate_size:  #终止已经在等待的那一部分线程
    
73.             self.q.put(StopEvent)
    
74.             generate_size -= 1
    
75. 
    
76. 
    
77. def func(li):
    
78.     for i in range(10000):
    
79.         li.append([i])
    
80. 
    
81. 
    
82. 
    
83. 
    
84. 
    
85. 
    
86. def world():
    
87.     wb = xw.Book.caller()
    
88.     li = []
    
89.     pool = TreadPool(5)
    
90.     for i in range(5):
    
91.         pool.run(target=func, args=(li,))
    
92.     pool.close()
    
93.     print(li)
    
94. 
    
95.     wb = xw.Book.caller()
    
96.     wb.sheets[0].range("a1").value = li

复制代码

水深与云起

这是网上找来的别人的代码

水深与云起

论坛里面其实也有相关的帖子，但是帖主自己找到了方法，没说是什么方法，伤心
https://bbs.125.la/forum.php?mod ... FD%BE%DD&page=1

水深与云起

现在我是已经在数组里有shuj了 求教如何快速导出到excel 单线程太慢了所以想着线程池多线程操作

水深与云起

由于我是在主线程创建excel对象，故多线程启动了不同的线程，没有创建Excel对象，无法操作同一个Excel，或者每个线程都创建对象，就没法合并数据到一个Excel，所以没法用多线程大批量录入Excel数据，听说任务压缩成一个元组加到队列里可以，希望各位大神指教，感激不尽！

水深与云起

东方优源 发表于 2020-5-20 16:54
Excel操作 大shuj  https://bbs.125.la/forum.php?mod=viewthread&tid=14413012

看看这个能不能解决

我的目的是为了实现写出到excel表格 加快速度 想着用多线程，如果有别的办法也好， 这个大shuj操作excel只能读取，读的速度我可以很快，多线程不成问题，写就不一样了，多线程写完后，因为对象不是同一个，没法合并shuj到一起保存 这是关键

水深与云起

我发现可以使用打开文件()命令打开excel，但是如何对excel写就不知道啦，这样可以多线程操作，求指导~