我希望用戶能夠在怎么開始的實現(xiàn)它？在

我的代碼是：# -*- coding: utf-8 -*-

from PySide import QtCore, QtGui

from Ui_MainWindow import Ui_MainWindow

from queue import Queue

import sys

import multiprocessing, os, time

def do_work():

print ('Work Started: %d' % os.getpid())

time.sleep(1)

return 'Success'

def manual_function(job_queue, result_queue):

while not job_queue.empty():

try:

job = job_queue.get(block=False)

result_queue.put(do_work())

except Queue.Empty:

pass

class Worker(QtCore.QThread):

def __init__(self,name):

QtCore.QThread.__init__(self)

self.name = name

self.pause = False

def run(self):

job_queue = multiprocessing.Queue()

result_queue = multiprocessing.Queue()

for i in range(1000):

job_queue.put(None)

self.workers = []

for i in range(6):

tmp = multiprocessing.Process(target=manual_function, args=(job_queue, result_queue))

tmp.start()

self.workers.append(tmp)

def paused(self):

'''

pause / resumme ?????????????????????????

'''

def stop(self):

for worker in self.workers:

print ("end")

worker.terminate()

worker.join()

class MainWindow(QtGui.QMainWindow):

def __init__(self, parent=None):

QtGui.QMainWindow.__init__(self, parent)

self.ui = Ui_MainWindow()

self.ui.setupUi(self)

self.connect(self.ui.actionStart, QtCore.SIGNAL('triggered()'),self.start)

self.connect(self.ui.actionStop, QtCore.SIGNAL('triggered()'),self.stop)

self.connect(self.ui.actionPause, QtCore.SIGNAL('triggered()'),self.pause)

def pause(self):

self.work.paused()

def stop(self):

self.work.stop()

def start(self):

self.threads = []

for tName in range(1):

self.work = Worker("Thread-%s"%tName)

self.threads.append(self.work)

self.work.start()

if __name__ == "__main__":

app = QtGui.QApplication (sys.argv)

window = MainWindow()

window.show()

sys.exit(app.exec_())

如何在Python中暫停按鈕點擊多處理過程？在

創(chuàng)作挑戰(zhàn)賽新人創(chuàng)作獎勵來咯，堅持創(chuàng)作打卡瓜分現(xiàn)金大獎

總結(jié)

以上是生活随笔為你收集整理的python进程暂停_如何在Python中暂停多进程？的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。