MultiProcessingSubscriber does not block for timeout #49

Closed
wants to merge 3 commits into
from

Conversation

Projects
None yet
2 participants
@ronaldevers

In the call to Queue.get in MultiProcessingSubscriber.recv, block should be True . If it is False, the timeout is ignored causing an immediate return and a 100%-cpu-usage loop in the subscriber thread as a consequence.

See also:

http://docs.python.org/library/multiprocessing.html#multiprocessing.Queue.get
http://docs.python.org/library/queue.html#Queue.Queue.get

@brainstorm

This comment has been minimized.

Show comment Hide comment
@brainstorm

brainstorm May 9, 2014

Collaborator

I cannot reproduce this lock actually. Plus, the PR cannot be merged.

Collaborator

brainstorm commented May 9, 2014

I cannot reproduce this lock actually. Plus, the PR cannot be merged.

@brainstorm brainstorm closed this May 9, 2014

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment