本文整理汇总了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;未经允许,请勿转载。 |
请发表评论