• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Python delayedresult.startWorker函数代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Python中wx.lib.delayedresult.startWorker函数的典型用法代码示例。如果您正苦于以下问题:Python startWorker函数的具体用法?Python startWorker怎么用?Python startWorker使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。



在下文中一共展示了startWorker函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Python代码示例。

示例1: OnConvert

    def OnConvert(self, evt):
        """Convert button event handler."""

        if self.converter and len(self.file_list):
            # Prompt the user to select a destination for the converted file
            saveDialog = wx.FileDialog(self, defaultDir=os.getcwd(),
                                        defaultFile="output.pdf",
                                        style=wx.FD_SAVE | wx.FD_OVERWRITE_PROMPT)

            if saveDialog.ShowModal() == wx.ID_OK:
                # Start the conversion process in a different thread
                outputPath = saveDialog.GetPath().replace(".pdf", "")
                startWorker(self.OnConversionCompleted, self.convertWorker,
                            wargs=([file.path for file in self.file_list], outputPath))

                # Show an indeterminate progress bar while the conversion is happening in the background.
                self.progressComplete = False
                self.keepGoing = True
                progressDialog = wx.ProgressDialog("Converting to sheet music",
                                                   "This may take a while...",
                                                   parent=self,
                                                   style=wx.PD_APP_MODAL | wx.PD_CAN_ABORT)

                while self.keepGoing and not self.progressComplete:
                    self.keepGoing = progressDialog.Pulse()[0]
                    wx.MilliSleep(30)
                progressDialog.Destroy()

                if os.path.exists(outputPath):
                    os.remove(outputPath)
开发者ID:joelrobichaud,项目名称:polyscribe,代码行数:30,代码来源:gui.py


示例2: OnNavigated

	def OnNavigated(self, event):
		url = event.GetURL()
		if url == 'https://www.dropbox.com/1/oauth2/authorize_submit':
			result = self.browser.RunScript("""
				if (!document.getElementsByClassName) {
    				document.getElementsByClassName=function(cn) {
        			var allT=document.getElementsByTagName('*'), allCN=[], i=0, a;
        			while(a=allT[i++]) {
            			a.className==cn ? allCN[allCN.length]=a : null;
        			}
        			return allCN
   					}
				}
				document.title = document.getElementsByClassName('auth-code')[0].innerText;
				""")
			auth_code = self.browser.GetCurrentTitle()
			self.parent.Hide()
			self.Destroy()
			
			track_event('Dropbox auth finished')

			startWorker(did_login, self.shotBufApp.did_finish_auth(auth_code))
			

		else:
			print 'Fail'
开发者ID:vladignatyev,项目名称:pastebotmurder,代码行数:26,代码来源:ShotBuf.py


示例3: FetchData

    def FetchData(self):
        self.checkList.Clear()
        self.checkListItems = []

        unselectedQualities = [self.listBoxItems[i] for i in range(
            len(self.listBoxItems)) if i not in self.listBox.GetSelections()]

        startWorker(self.OnDataFetched, self.FetchDataWorker, wargs=(
            self.listUrlTextInput.GetLineText(0),
            unselectedQualities,
            int(self.comboBox.GetSelection()) + 1,
            self.userConfig["aliases"]))

        # Progress Dialog
        self.progress = 0
        self.keepGoing = True
        progressDialog = wx.ProgressDialog("Fetching data",
                                           "This may take a while...",
                                           parent=self,
                                           style=wx.PD_APP_MODAL | wx.PD_CAN_ABORT | wx.PD_AUTO_HIDE)

        while self.keepGoing and self.progress < 100:
            wx.MilliSleep(250)
            wx.Yield()
            (self.keepGoing, skip) = progressDialog.Update(self.progress)
        progressDialog.Destroy()
开发者ID:joelrobichaud,项目名称:anidl,代码行数:26,代码来源:anidl.py


示例4: runMeasurement

 def runMeasurement(self, devices,autoMeasure):
     """ Runs the automatic measurement."""
     self.numDevices = len(devices)
     self.gauge.SetRange(self.numDevices)
     self.text.SetLabel('0 out of %d devices measured'%self.numDevices)
     # Run the automatic measurement in a separate thread so it doesnt block the GUI.
     startWorker(self.measurementDoneCb, self.doMeasurement, wargs=(autoMeasure,devices,self.checkAborted,self.slowThreadUpdateGauge))
     self.ShowModal()
开发者ID:StephenHLin,项目名称:pyOptomip,代码行数:8,代码来源:autoMeasureProgressDialog.py


示例5: handleGet

 def handleGet(self, event): 
     """Compute result in separate thread, doesn't affect GUI response."""
     self.buttonGet.Enable(False)
     self.buttonAbort.Enable(True)
     self.abortEvent.clear()
     self.jobID += 1
     
     DR.startWorker(self._resultConsumer, self._resultProducer, 
                               wargs=(self.jobID,self.abortEvent), jobID=self.jobID)
开发者ID:court-jus,项目名称:bgm,代码行数:9,代码来源:formatadvancedialog.py


示例6: Update

def Update(parent):
    """ This is a thread for _Update """
    ghrepo="ZELLMECHANIK-DRESDEN/ShapeOut"
    parent.StatusBar.SetStatusText("Checking for updates...")
    version = so_version.version
        
    delayedresult.startWorker(_UpdateConsumer, _UpdateWorker,
                              wargs=(ghrepo, version),
                              cargs=(parent,))
开发者ID:ZELLMECHANIK-DRESDEN,项目名称:ShapeOut,代码行数:9,代码来源:update.py


示例7: OnGetKOM

 def OnGetKOM(self, event):
     print 'OK'
     self.button_GetKOM.Enable(False)
     print u'Тянем KOMMENTARI'
     self.abortEvent.clear()
     self.jobID += 1
     delayedresult.startWorker(self._resultConsumerKOM,
                               self._resultProducerKOM,
                               wargs=(self.jobID,self.abortEvent),
                               jobID=self.jobID)
开发者ID:pillserg,项目名称:PaperDonkey,代码行数:10,代码来源:ggGui.py


示例8: OnGetUK

    def OnGetUK(self, event):

        self.button_GetUK.Enable(False)
        print u'Тянем Урядовый курьер за %s'%self.text_UK_Date.GetValue()
        self.abortEvent.clear()
        self.jobID += 1
        delayedresult.startWorker(self._resultConsumerUK,
                                  self._resultProducerUK,
                                  wargs=(self.jobID,self.abortEvent),
                                  jobID=self.jobID)
开发者ID:pillserg,项目名称:PaperDonkey,代码行数:10,代码来源:ggGui.py


示例9: OnGetRG

    def OnGetRG(self, event):

        self.button_GetRG.Enable(False)
        print u'Тянем рабочку за %s'%self.text_UK_Date.GetValue()
        self.abortEvent.clear()
        self.jobID += 1
        delayedresult.startWorker(self._resultConsumerRG,
                                  self._resultProducerRG,
                                  wargs=(self.jobID,self.abortEvent),
                                  jobID=self.jobID)
开发者ID:pillserg,项目名称:PaperDonkey,代码行数:10,代码来源:ggGui.py


示例10: OnGetDAY

    def OnGetDAY(self, event):

        self.button_GetDAY.Enable(False)
        print u'Тянем ДЕНЬ'
        self.abortEvent.clear()
        self.jobID += 1
        delayedresult.startWorker(self._resultConsumerDAY,
                                  self._resultProducerDAY,
                                  wargs=(self.jobID,self.abortEvent),
                                  jobID=self.jobID)
开发者ID:pillserg,项目名称:PaperDonkey,代码行数:10,代码来源:ggGui.py


示例11: OnGetZN

 def OnGetZN(self, event):
     print 'OK'
     self.button_GetZN.Enable(False)
     print u'Тянем Зеркало Недели'
     self.abortEvent.clear()
     self.jobID += 1
     delayedresult.startWorker(self._resultConsumerZN,
                               self._resultProducerZN,
                               wargs=(self.jobID,self.abortEvent),
                               jobID=self.jobID)
开发者ID:pillserg,项目名称:PaperDonkey,代码行数:10,代码来源:ggGui.py


示例12: OnGetCV

 def OnGetCV(self, event):
     print 'OK'
     self.button_GetCV.Enable(False)
     print u'Тянем CV'
     self.abortEvent.clear()
     self.jobID += 1
     delayedresult.startWorker(self._resultConsumerCV,
                               self._resultProducerCV,
                               wargs=(self.jobID,self.abortEvent),
                               jobID=self.jobID)
开发者ID:pillserg,项目名称:PaperDonkey,代码行数:10,代码来源:ggGui.py


示例13: __call__

    def __call__(self):
        """ Make the call! """

        # Display the progress dialog (we do it here and NOT in the result
        # producer because the producer is NOT in the GUI thread!).
        self._open_progress_dialog()

        import wx.lib.delayedresult as delayedresult
        delayedresult.startWorker(self._result_consumer, self._result_producer)

        return
开发者ID:bobye,项目名称:uchicago-pyanno,代码行数:11,代码来源:long_running_call.py


示例14: onAnuncios

    def onAnuncios(self, event):

        # global lista_anuncios
        # message = "Analizando el archivo %s " %str(self.currentFile)
        # busy = PBI.PyBusyInfo(message, parent=None, title="Procesando")
        # #lista_anuncios=delayedresult.startWorker(self.tonteriamaxima,self.reconocer_huellas())
        # lista_anuncios=self.reconocer_huellas()
        # wx.Yield()
        # del busy

        delayedresult.startWorker(self.resultConsumer, self.resultProducer, wargs=(self.currentFile,))
开发者ID:Edasn,项目名称:CaptorRadio-v2,代码行数:11,代码来源:interfaz2.py


示例15: handleGet

 def handleGet(self, event): 
     """Compute result in separate thread, doesn't affect GUI response."""
     self.buttonGet.Enable(False)
     self.buttonAbort.Enable(True)
     self.abortEvent.clear()
     self.jobID += 1
     
     self.log( "Starting job %s in producer thread: GUI remains responsive"
               % self.jobID )
     delayedresult.startWorker(self._resultConsumer, self._resultProducer, 
                               wargs=(self.jobID,self.abortEvent), jobID=self.jobID)
开发者ID:PREM1980,项目名称:ecomstore,代码行数:11,代码来源:DelayedResult.py


示例16: Update

def Update(parent):
    """ This is a thread for _Update """
    ghrepo="ZellMechanik-Dresden/ShapeOut"
    parent.StatusBar.SetStatusText("Checking for updates...")
    if hasattr(so_version, "repo_tag"):
        version = so_version.repo_tag  # @UndefinedVariable
    else:
        version = so_version.version
        
    delayedresult.startWorker(_UpdateConsumer, _UpdateWorker,
                              wargs=(ghrepo, version),
                              cargs=(parent,))
开发者ID:DerDeef,项目名称:ShapeOut,代码行数:12,代码来源:update.py


示例17: TestCaseRunDialog

    def TestCaseRunDialog(self, testcase):

        self.abortEvent = delayedresult.AbortEvent()
        self.abortEvent.clear()
        self.jobID = 1
        self.runFlag = True  # testcases were completed, destory dlg
        testKeepGoing = True

        self.dlg = wx.ProgressDialog('Executing test suite progress',
                                     'Running......please wait.',
                                     maximum=50,
                                     parent=self,
                                     style=0
                                           | wx.PD_APP_MODAL
                                           | wx.PD_CAN_ABORT
                                           ##                        | wx.PD_CAN_SKIP
                                           | wx.PD_ELAPSED_TIME
                                           | wx.PD_REMAINING_TIME
                                     ##                        | wx.PD_AUTO_HIDE
                                     )

        delayedresult.startWorker(self.DestoryTestCaseRunDialog, self.TextTestRunnerFailCheck,
                                  wargs=(self.jobID, self.abortEvent, testcase, v.FAIL_RETRY),
                                  jobID=self.jobID)

        # start memory monitor
        self.memMon = mm.HttpMemCPUMonitor(v.MEM_MONITOR_INTERVAL)
        self.memMon.start()

        if v.CONNECTION_TYPE is not 3:
            self.memMonXlsx = mm.MemMonitorXlsx(v.MEM_MONITOR_INTERVAL, file=v.MAIL_XLSX)
            # self.memMonXlsx.setDaemon(True)
            self.memMonXlsx.start()

        while testKeepGoing and self.runFlag:
            wx.Yield()  # refresh progress
            (testKeepGoing, skip) = self.dlg.Pulse()
            t.sleep(0.1)
            # set testKeepGoing to False when click cancel

        if os.path.exists(v.TEST_SUITE_LOG_PATH):
            if not os.path.exists(v.REPORT_NAME):
                os.rename(v.TEST_SUITE_LOG_PATH, v.REPORT_NAME)
            else:
                os.rename(v.TEST_SUITE_LOG_PATH, v.REPORT_NAME + "_" + str(random.randint(1, 9999)))

        if testKeepGoing is False: # click cancel
            os.system("taskkill /F /IM python.exe | taskkill /F /T /IM adb.exe")
        else: # reboot android device
            co.setAdbReboot(v.ANDROID_SERIAL_NUM, v.DEVICE_STATUS_LOG)
        self.abortEvent.set()
        self.dlg.Destroy()
开发者ID:wucaicheng,项目名称:peanuts,代码行数:52,代码来源:main.py


示例18: _renderstart

 def _renderstart(self):
     self.abortEvent.clear()
     self.rendering = True
     self.html.UpdateRenderText(_("Started..."))
     self.jobID += 1
     
     params = self.createParams()
     print "-"*20
     for p in params:
         print type(p), p
     
     delayedresult.startWorker(self._resultConsumer, self._resultProducer,
             wargs=(self.jobID,self.abortEvent, params), jobID=self.jobID)
开发者ID:IzAndCuddles,项目名称:MapTiler,代码行数:13,代码来源:main.py


示例19: DelayedWorkerLoadData

 def DelayedWorkerLoadData(self):
     if hasattr(self.gauge, "Pulse"):
         self.gauge.Pulse()
     else:
         self.gauge.SetRange(2)
         self.gauge.SetValue(1)
         
     self.tc.SetValue("Loading...")
     self.job_id += 1
     self.url.Insert(self.url.GetValue(),0)
     self.SaveState()
     delayedresult.startWorker(self.LoadComplete, self.LoadData, 
                                       jobID=self.job_id)
开发者ID:isyippee,项目名称:informal,代码行数:13,代码来源:restclient.py


示例20: UpdateList

    def UpdateList(self, url=PLUGIN_REPO):
        """Update the list of available downloads
        @param url: url to fetch update list from
        @postcondition: Worker thread is started that will update list when it
                        finishes.

        """
        if self._list.GetItemCount():
            self._list.DeleteAllItems()
        frame = self.GetGrandParent()
        frame.SetStatusText(_("Retrieving Plugin List") + "...", 0)
        frame.Busy(True)
        delayedresult.startWorker(self._UpdateCatcher, _GetPluginListData, wkwargs={"url": url}, jobID="update")
开发者ID:BioinformaticsArchive,项目名称:gengis,代码行数:13,代码来源:plugdlg.py



注:本文中的wx.lib.delayedresult.startWorker函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Python listctrl.CheckListCtrlMixin类代码示例发布时间:2022-05-26
下一篇:
Python wx.version函数代码示例发布时间:2022-05-26
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap