update
This commit is contained in:
@@ -21,7 +21,9 @@ from multiprocessing import Queue, Process
|
|||||||
import queue
|
import queue
|
||||||
from decimal import Decimal, getcontext
|
from decimal import Decimal, getcontext
|
||||||
|
|
||||||
DELAY1 = 80
|
import time
|
||||||
|
|
||||||
|
DELAY1 = 20
|
||||||
DELAY2 = 20
|
DELAY2 = 20
|
||||||
|
|
||||||
class Example(Frame):
|
class Example(Frame):
|
||||||
@@ -116,7 +118,8 @@ class Example(Frame):
|
|||||||
print (self.p1.is_alive())
|
print (self.p1.is_alive())
|
||||||
|
|
||||||
queue.put(pi)
|
queue.put(pi)
|
||||||
print("end")
|
print("end")
|
||||||
|
time.sleep(1)
|
||||||
|
|
||||||
|
|
||||||
def main():
|
def main():
|
||||||
|
|||||||
@@ -53,13 +53,13 @@ def sourcedir_foldercnt(sourcedir):
|
|||||||
#print(len(folderlist))
|
#print(len(folderlist))
|
||||||
return cnt
|
return cnt
|
||||||
|
|
||||||
def process_files(source, dest):
|
def process_files(gui, source, dest):
|
||||||
global sourcedir
|
global sourcedir
|
||||||
global destdir
|
global destdir
|
||||||
sourcedir = source
|
sourcedir = source
|
||||||
destdir = dest
|
destdir = dest
|
||||||
pool = mp.Pool(processes=num_cores)
|
pool = mp.Pool(processes=num_cores)
|
||||||
pool.map(process_file, filelist)
|
pool.map(process_file, filelist, gui)
|
||||||
|
|
||||||
def process_file(data):
|
def process_file(data):
|
||||||
outfile = ''
|
outfile = ''
|
||||||
@@ -106,7 +106,7 @@ def process_file(data):
|
|||||||
newfile = open(outputfile, "w")
|
newfile = open(outputfile, "w")
|
||||||
newfile.write(outfile)
|
newfile.write(outfile)
|
||||||
newfile.close()
|
newfile.close()
|
||||||
|
|
||||||
def async_process(num):
|
def async_process(num):
|
||||||
pool = mp.Pool(processes=num)
|
pool = mp.Pool(processes=num)
|
||||||
pool.map(process_file, filelist)
|
pool.map(process_file, filelist)
|
||||||
Reference in New Issue
Block a user