1

我编写了一个 wxpython 应用程序，它使用了几个不同的线程，所有这些线程都需要写入日志窗口（textctrl 框）。因此，我遵循了本教程

http://www.blog.pythonlibrary.org/2010/05/22/wxpython-and-threads/

并使用了 wx.CallAfter 和 PubSub。

这是我的原始代码

from wx.lib.pubsub import Publisher

Publisher().subscribe(self.messenger, "update")

wx.CallAfter(Publisher().sendMessage, "update", "Thread finished!")

def messenger(self, msg):
    self.logtxtctrl.WriteText(msg.data)

这段代码运行得很好，并认为使用 pyinstaller 为我的代码创建一个 exe 会很容易。

我错了！！

所以在阅读了一些评论之后，似乎有两个版本的 pubSub API，所以使用这个

http://wiki.wxpython.org/WxLibPubSub

我将我的代码调整为以下

from wx.lib.pubsub import setuparg1

from wx.lib.pubsub import pub

pub.subscribe(self.messenger, "update")

wx.CallAfter(pub.sendMessage, "update", data="Program success")

def messenger(self, data):
    self.logtxtctrl.WriteText(data)

这段代码现在可以工作了，我再次尝试使用 pyinstaller 仍然没有运气。

所以我然后阅读了以下文章

如何让 pubsub 与 pyinstaller 一起工作？

http://www.pyinstaller.org/ticket/312

两者都非常有用，我尝试了更改挂钩文件和不同规范文件的所有不同变体，但我仍然无法让它工作。

这些帖子几乎是 2 年前的事了，我原以为添加 pubsub 会解决。

谁能解释一下我需要什么钩子的过程，规范文件中的内容以及我需要做的其他元素才能让它工作？

如果没有解决方案，我还能如何与小部件进行线程安全通信？

4

1 回答 1

0

尝试

from wx.lib.pubsub import setupkwargs
from wx.lib.pubsub import pub

我有一个程序可以完全满足您的需求。我使用的相关代码如下。我建议创建一个函数，Logger而不是使用 WriteText，它在更改发生时为我节省了一些痛苦。

class Frame(wx.Frame):
    def __init__(self, *args, **kwargs):
        super(Frame, self).__init__(*args, **kwargs)
        self.InitUI()
        self.SetSize((380,340))
        self.Show()
        self.count = 0
        self.threads = []
        pub.subscribe(self.__StatusChanged, 'status.changed')

    def __StatusChanged(self, asset, time, status):
        if status:
            msg = 'Online'
        else:
            msg = 'Offline'
        self.Logger('{}: {} - {}\n'.format(time, asset, msg))

    def Logger(self, msg):
        self.txtresults.AppendText(msg)

class PingAssets(threading.Thread):
    def __init__(self, threadNum, asset, window):
        threading.Thread.__init__(self)
        self.threadNum = threadNum
        self.window = window
        self.asset = asset
        self.signal = True
        self.status = None

    def run(self):
        while self.signal:
            logging.debug("Thread {} started run sequence.".format(self.threadNum))
            start_time = datetime.now().strftime(self.fmt)
            try:
                newstatus = onlinecheck.check_status(self.asset)
                if newstatus != self.status or self.verbose:
                    self.status = newstatus
                    pub.sendMessage('status.changed', asset=self.asset,
                                    time=start_time, status=self.status)
于 2013-08-20T15:43:38.983 回答