YunoHost/moulinette
1
0
Fork 0
mirror of https://github.com/YunoHost/moulinette.git synced 2024-09-03 20:06:31 +02:00
Code Issues Projects Releases Packages Wiki Activity

Merge ff59ee4676 into 06626f69c4

Browse source
This commit is contained in:
Bram 2018-06-23 09:02:31 +00:00 • committed by GitHub
commit f6ad39bcef
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
moulinette/utils/stream.py
View file

@ -1,3 +1,5 @@
import threading
from multiprocessing.process import Process from multiprocessing.process import Process
from multiprocessing.queues import SimpleQueue from multiprocessing.queues import SimpleQueue
@ -55,6 +57,6 @@ def async_file_reading(fd, callback):
queue = SimpleQueue() queue = SimpleQueue()
reader = AsynchronousFileReader(fd, queue) reader = AsynchronousFileReader(fd, queue)
reader.start() reader.start()
consummer = Process(target=consume_queue, args=(queue, callback)) consummer = threading.Thread(target=consume_queue, args=(queue, callback))
consummer.start() consummer.start()
return (reader, consummer) return (reader, consummer)