Multi-threading no aplicativo projetado rapidamente

1

Eu tenho uma árvore que eu preenche com uma lista de arquivos do meu computador no clique de um botão. Enquanto o programa está preenchendo a árvore, toda a GUI trava.

Existe uma maneira de preencher a árvore em outro thread para que a árvore seja preenchida quando os arquivos forem encontrados e não quando tudo já tiver sido adicionado? Ou alguma outra ideia?

Isto é o que parece:

Estoupreenchendoaárvorecomestecódigo:

deftraversePaths(self,path,parent):files=os.listdir(path)files.sort()formyfileinfiles:ifmyfile[0]!=".":
                if os.path.isdir(path + os.sep + myfile):
                    current = self.filelist.append(parent,[self.dirIcon,self.dirIcon,self.dirOpenIcon,myfile,"DD",True,True,3])
                    self.traversePaths(path + os.sep + myfile, current)
                else:
                    current = self.filelist.append(parent,[self.fileIcon,self.dirIcon,self.dirOpenIcon,myfile,"AA",True,True,3])

que é executado em um clique de botão:

def on_refreshbutton_clicked(self, button):
    self.traversePaths(self.path.get_filename(), None)

Eu não acho que o threading.Thread funcione por causa do thread do gtk para o gui e não consiga encontrar o gi.repository.Gtk api sobre o assunto

Alguma idéia?

    
por ender 23.08.2012 / 16:50

2 respostas

2

Ao fazer perguntas de programação, é sempre melhor fornecer um exemplo de trabalho mínimo e não apenas trechos de código.

Sem um exemplo de trabalho para brincar, tenho as seguintes sugestões:

  1. Use um thread para percorrer a árvore de diretórios e coloque seus resultados em um segundo treemodel separado (não conectado a um treeview). Isso significa que você tem dois treemodels, um conectado (que é renderizado na tela) e um não conectado (que, portanto, não é renderizado)
  2. Adicione um tempo limite de alguns segundos, que chama uma função que desanexa e exclui o primeiro treemodel, copia o segundo treemodel para um novo, que agora serve como o treemodel "thread" e anexa o segundo modelo de árvore. / li>

A razão pela qual você vê a GUI pendurada é que o arquivo walker leva muito tempo e toda vez que você adiciona um arquivo, muita sobrecarga no Gtk é chamada. Ao adicionar um treemodel completo, essa sobrecarga é chamada apenas uma vez. E usando um thread para o arquivo andando, sua GUI permanece responsiva.

Quanto à parte de threading no Gtk, talvez você queira procurar aqui: link

Algumas notas para o seu código:

  • O Python tem um walk-in de arquivo embutido, que pode ser mais rápido, mas certamente menor do que o seu código: os.walk
  • Se você quiser usar seu código, lembre-se de que o Python possui um limite de recursão embutido. Dependendo do tamanho do seu sistema de arquivos, talvez você queira substituir a recursão por uma construção semelhante a um trampolim
por xubuntix 24.08.2012 / 09:37
1

Veja um exemplo completo que atualiza a árvore simultaneamente usando uma única TreeStore :

#!/usr/bin/python
import os
import threading
import time
from itertools import cycle

from gi.repository import GObject, Gtk
GObject.threads_init()  # all Gtk is in the main thread;
                        # only GObject.idle_add() is in the background thread


HEARTBEAT = 20   # Hz
CHUNKSIZE = 100  # how many items to process in a single idle_add() callback


def chunks(seq, chunksize):
    """Yield N items at a time from seq."""
    for i in xrange(0, len(seq), chunksize):
        yield seq[i:i + chunksize]


class TreeStore(Gtk.TreeStore):
    __gtype_name__ = 'TreeStore'

    def __init__(self, topdir, done_callback=None):
        Gtk.TreeStore.__init__(self, str)  # super() doesn't work here

        self.path2treeiter = {topdir: None}  # path -> treeiter
        self.topdir = topdir
        self.done_callback = done_callback
        self._cv = threading.Condition()

        t = threading.Thread(target=self._build_tree)
        t.daemon = True
        t.start()  # start background thread

    def _build_tree(self, _sentinel=object()):
        # executed in a background thread
        cv = self._cv
        p = self.path2treeiter
        for dirpath, dirs, files in os.walk(self.topdir):
            # wait until dirpath is appended to the tree
            cv.acquire()
            while p.get(dirpath, _sentinel) is _sentinel:
                cv.wait()
            parent = p[dirpath]
            cv.release()

            # populate tree store
            dirs[:] = sorted(d for d in dirs
                             if d[0] != '.')  # skip hidden dirs
            for chunk in chunks(dirs, CHUNKSIZE):
                GObject.idle_add(self._appenddir, chunk, parent, dirpath)

            for chunk in chunks(sorted(files), CHUNKSIZE):
                GObject.idle_add(self._appendfile, chunk, parent)
        GObject.idle_add(self.done_callback)

    def _appenddir(self, chunk, parent, dirpath):
        # executed in the main thread
        self._cv.acquire()
        p = self.path2treeiter
        for d in chunk:
            p[os.path.join(dirpath, d)] = self.append(parent, [d])
        self._cv.notify()
        self._cv.release()

    def _appendfile(self, chunk, parent):
        # executed in the main thread
        for f in chunk:
            self.append(parent, [f])


class Window(Gtk.Window):
    __gtype_name__ = 'Window'

    def __init__(self, topdir):
        super(Window, self).__init__(type=Gtk.WindowType.TOPLEVEL)
        self.__start_time = time.time()
        self.__title = 'GTK Tree MultiThreading Demo'
        self.set_title(self.__title)
        self.set_default_size(640, 480)

        # create tree
        tree_store = TreeStore(topdir, self._on_tree_completed)
        tree_view = Gtk.TreeView()
        tree_view.set_model(tree_store)

        cell = Gtk.CellRendererText()
        tree_view.append_column(Gtk.TreeViewColumn(topdir, cell, text=0))
        scrolled_window = Gtk.ScrolledWindow()
        scrolled_window.add(tree_view)
        self.add(scrolled_window)

        # update title to show that we are alive
        self._update_id = GObject.timeout_add(int(1e3 / HEARTBEAT),
                                              self._update_title)

    def _on_tree_completed(self):
        if self._update_id is None:
            return
        # stop updates
        GObject.source_remove(self._update_id)
        self._update_id = None
        self.set_title('%s %s %.1f' % (self.__title, ' (done)',
                                       time.time() - self.__start_time))

    def _update_title(self, _suff=cycle('/|\-')):
        self.set_title('%s %s %.1f' % (self.__title, next(_suff),
                                       time.time() - self.__start_time))
        return True  # continue updates


win = Window(topdir=os.path.expanduser('~'))
win.connect('delete-event', Gtk.main_quit)
win.show_all()
Gtk.main()

Como @xubuntix disse , cada treestore.append() é caro neste caso. Veja se é aceitável para você.

    
por jfs 02.09.2012 / 19:01