我正在用pygtk编写一个工具,它需要递归地解析大目录,并将结果匹配的文件添加到列表中。这个过程显然会导致用户界面挂断,因此我尝试使用多处理库。在
在我提出解决方案之前,我需要更多的背景知识: -这个程序有两个主要类,一个是完成所有密集工作并与UI对话的controller类;另一个是模型类,用于处理工具所需的所有数据。在
import sys
import os
import pygtk
import fnmatch
from multiprocessing import Pool
pygtk.require("2.0")
#try:
from gi.repository import Gtk
from gi.repository import GObject
#except:
# print("GTK Not Availible")
# sys.exit(1)
class Controller(object):
def __init__(self,builder,model):
self.builder=builder
self.model=model
def btn_pass_clicked(self, *args,**kwargs):
print "it's working!, its woooooorkkinnnnggg!"
spinnywheel= self.builder.get_object("activitySpinner")
spinnywheel.start()
def btn_fail_clicked(self, *args, **kwargs):
print "stopping spinnywheel!"
spinnywheel=self.builder.get_object("activitySpinner")
spinnywheel.stop()
def quit(self,*args,**kwargs):
print "iamquit"
Gtk.main_quit()
def file_menu_open(self,*args,**kwargs):
print "file->open"
self.builder.get_object("openDialogue").show()
def opendialogue_btnOpen_clicked(self,*args,**kwargs):
rootdir = os.path.expanduser(self.builder.get_object("openDialogue_entryBox").get_text())
self.builder.get_object("openDialogue").hide()
self.builder.get_object("openDialogue_entryBox").set_text("")
if os.path.exists(rootdir):
self.builder.get_object("activitySpinner").start()
print "pooling workers and walking ",rootdir
p = Pool(None)
p.apply_async(self.walk_for_files,rootdir,None,self.finished_recurse)
else:
print "Path does not exist!"
def walk_for_files(self,rootdir):
for root,dirs,files in os.walk(rootdir):
for extension in ['c','cpp']:
for filename in fnmatch.filter(files,'*.'+extension):
self.model.add_single_file(os.path.join(root,filename))
def finished_recurse(self,*args,**kargs):
print "workers finished parsing dirs!"
self.builder.get_object("activitySpinner").stop()
class Model(object):
def __init__(self):
self.fileList=[]
def add_single_file(self,file):
self.fileList.append(file)
print "added ",file
class Scrutiny(object):
def __init__(self):
builder = Gtk.Builder()
builder.add_from_file("scrutinydev.ui")
model_object=Model()
controller_object=Controller(builder,model_object)
builder.connect_signals(controller_object)
builder.get_object("windowMain").show()
builder.get_object("listView")
GObject.threads_init()
Gtk.main()
if __name__ == "__main__":
scrutiny = Scrutiny()
现在,这是我的问题。在
如您所见,使用pool()派生的worker需要执行回调finish\u recurse,这样我就可以停止GtkSpinner和其他UI工作。在
当代码处于当前状态时,我得到一个pickle错误
^{pr2}$我明白这是因为我无法序列化回调,我希望能为解决方法/修复提供建议,以实现我的需要。在
我不太了解GTK,但我认为你的问题更多的是酸洗而不是多处理。在
pickle module的getstate和setstate方法可以自定义任何对象的酸洗过程。在
下面是一个简单的例子来说明它是如何工作的:
当然,表示和正确恢复对象的状态仍然是开发人员的责任。在
相关问题 更多 >
编程相关推荐