Odoo中文社区可以通过以下两个域名访问：shine-it.net , odoo.net.cn
由于系统升迁的原因，本论坛部分较早期的内容存在格式和链接损坏失效的问题，并非本论坛系统本身的缺陷，望谅解
本社区没有维护任何QQ群讨论组，任何与本社区同名的QQ群讨论组的言论与本社区无关!
开发人员可以登录gitter讨论组: http://gitter.im/odoo-china/Talk, 需要github账号
如果您登录系统碰到问题，请在微信公众号留言：
Python多线程（threading）
-
<br /># -*- coding: utf-8 -*- <br />#author:ghoti<br />'''自定义多线程运行函数，可定义同时运行个数'''<br />import threading,time<br />from time import sleep,ctime<br />class My_Thead:<br /> '''<br /> 多线程运行函数，将all_list切片处理，num为进程数，all_list小于num，单线程运行，<br /> sleep_time为单个进程（一个all_list切片）运行后停留时间（方便调试），<br /> myfunc为处理每个切片的函数，对all_list切片，在处理<br /> '''<br /> def __init__ (self, all_list, num, sleep_time=0, myfunc=None):<br /> self.all_list = all_list<br /> self.len_list = len(all_list)<br /> self.num = num #进程数,实际进程为可能为num+1<br /> if len(all_list)<num:<br /> self.num = 1<br /> self.m = self.len_list/self.num<br /> if not self.m:<br /> self.m = 1<br /> self.loops=range(0 , self.len_list, self.m)<br /> self.sleep_time = sleep_time<br /> self.myfunc = myfunc<br /> def loop (self,nloop,n,m):<br /> self.myfunc(n,m)<br /> sleep(self.sleep_time)<br /> def __call__ (self):<br /> if not self.all_list:<br /> return False<br /> threads=[]<br /> nloops=range(len(self.loops))<br /> for i in nloops:<br /> t=threading.Thread(target=self.loop,args=(i, self.loops[i], self.m))<br /> threads.append(t)<br /> for i in nloops:<br /> threads[i].start()<br /> for i in nloops:<br /> threads[i].join()<br /><br />'''<br />##how to use<br />#from my_thread import My_Thead<br />all_list = range(103)<br />def myfunc(n,m):<br /> part_list = all_list[n:n+m]<br /> for i in part_list:<br /> print i,<br />My_Thead(range(103),5,myfunc=myfunc)()<br />'''<br /><br />''' <br />## use in oe<br /> def myfunc(n,m):<br /> part_list = rsps[n:n+m]<br /> for rsp in part_list:<br /> self.action_do_product(cr, uid, ids, rsp, context=None):<br /> <br /> from openerp.addons.basefunc.my_thread import My_Thead<br /> My_Thead(rsps,10,myfunc=myfunc)()<br />'''<br /> -
OE 使用多线程 可以看看 cron 的处理代码...
-
恩恩，这个写的通用性强些，不仅在oe，其它地方也可以用
