filedownloader.py 文件源码

def main():
    sl = SL();os.system("mkdir /tmp/site");os.system("echo False > /tmp/site/site-log.txt")
    if sl.run() == Gtk.ResponseType.ACCEPT:
        sl.hide()
        #if sl.button.get_label()!='Select folder':
        folder = '/tmp/site/';
        extension = sl.entry10.get_text()
        url = sl.entry11.get_text()
        if len(url)>0:
            urls = get_file_urls(url,extension)
            total = len(urls)
            if total>0:
                print(urls)
                workers = []
                print(1)
                cua = queue.Queue(maxsize=total+2)
                progreso = Progreso('Downloading from %s'%url,None,total)
                total_workers = total if NUM_THREADS > total else NUM_THREADS
                for i in range(total_workers):
                    worker = Worker(cua,folder)
                    worker.connect('downloaded',progreso.increase)
                    worker.start()
                    workers.append(worker)
                print(2)
                for aurl in urls:
                    cua.put(aurl)
                # block until all tasks are done
                print(3)
                cua.join()
                # stop workers
                print(4)
                for i in range(total_workers):
                    cua.put(None)
                for worker in workers:
                    worker.join()
                    while Gtk.events_pending():
                        Gtk.main_iteration()

                os.system("echo True > /tmp/site/site-log.txt")