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

[moÃd] uses thread to allow callback to modify the context

Browse source
This commit is contained in:
Laurent Peuch 2018-06-08 23:47:45 +02:00
parent cee5eb562a
commit ff59ee4676
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)