[issue8237] multiprocessing.Queue() blocks program

[Erdem U. Altinyurt]

Erdem U. Altinyurt spamjunkea...@gmail.com added the comment:

Firstly I think as you but this is not correct.
Added Q.full() to know if Queue is full or not to the testQ code..

def testQ():
   for i in range(1):
  mp.Process( None, QueueWorker, None, (i,Q,lock) ).start()
  while len(mp.active_children())=mp.cpu_count()+4:
time.sleep(0.01)
print Q.full()

output is:
1397  done
1398  done
1399  done
False
False
False

So Queue is not full. And you can also add some things to queue at this 
state(by adding extra line to  while loop) and this will not blocks while loop.

Please test..

--
status: closed - open

___
Python tracker rep...@bugs.python.org
http://bugs.python.org/issue8237
___
___
Python-bugs-list mailing list
Unsubscribe: 
http://mail.python.org/mailman/options/python-bugs-list/archive%40mail-archive.com

[issue8237] multiprocessing.Queue() blocks program

[Erdem U. Altinyurt]

New submission from Erdem U. Altinyurt spamjunkea...@gmail.com:

multiprocessing.Queue() blocking program on my computer after adding 1400 entry 
(depending addition size).

Tested with 2.6.2 and 2.6.5(compiled from source with gcc 4.4.1)
Using 64 bit OpenSUSE  11.2.

Output is:
---

1398  done
1399  done
---

and enters deadlock because Q.put() cannot completed.
No problems with basic array with lock().
Here the result after pressing CTRL+C:

---
^CTraceback (most recent call last):
  File stdin, line 1, in module
  File stdin, line 5, in testQ
KeyboardInterrupt
 
^CError in atexit._run_exitfuncs:
Traceback (most recent call last):
  File /opt/python/lib/python2.6/atexit.py, line 24, in _run_exitfuncs
func(*targs, **kargs)
  File /opt/python/lib/python2.6/multiprocessing/util.py, line 269, in 
_exit_function
p.join()
  File /opt/python/lib/python2.6/multiprocessing/process.py, line 119, in join
res = self._popen.wait(timeout)
  File /opt/python/lib/python2.6/multiprocessing/forking.py, line 117, in wait
return self.poll(0)
  File /opt/python/lib/python2.6/multiprocessing/forking.py, line 106, in poll
pid, sts = os.waitpid(self.pid, flag)
KeyboardInterrupt
Error in sys.exitfunc:
Traceback (most recent call last):
  File /opt/python/lib/python2.6/atexit.py, line 24, in _run_exitfuncs
func(*targs, **kargs)
  File /opt/python/lib/python2.6/multiprocessing/util.py, line 269, in 
_exit_function
p.join()
  File /opt/python/lib/python2.6/multiprocessing/process.py, line 119, in join
res = self._popen.wait(timeout)
  File /opt/python/lib/python2.6/multiprocessing/forking.py, line 117, in wait
return self.poll(0)
  File /opt/python/lib/python2.6/multiprocessing/forking.py, line 106, in poll
pid, sts = os.waitpid(self.pid, flag)
KeyboardInterrupt

--
components: Library (Lib)
files: damine6.py
messages: 101740
nosy: eua
severity: normal
status: open
title: multiprocessing.Queue() blocks program
type: crash
versions: Python 2.6
Added file: http://bugs.python.org/file1/damine6.py

___
Python tracker rep...@bugs.python.org
http://bugs.python.org/issue8237
___
___
Python-bugs-list mailing list
Unsubscribe: 
http://mail.python.org/mailman/options/python-bugs-list/archive%40mail-archive.com