This issue tracker has been migrated to GitHub, and is currently read-only.
For more information, see the GitHub FAQs in the Python's Developer Guide.

classification
Title: Multiprocessing Array and sharedctypes.Array error in docs/implementation
Type: Stage:
Components: Documentation, Library (Lib) Versions: Python 3.0
process
Status: closed Resolution: duplicate
Dependencies: Superseder: AssertionError in Doc/includes/mp_benchmarks.py
View: 4449
Assigned To: jnoller Nosy List: georg.brandl, jnoller, mishok13, roudkerk, sgala
Priority: normal Keywords: patch

Created on 2008-06-26 09:53 by mishok13, last changed 2022-04-11 14:56 by admin. This issue is now closed.

Files
File name Uploaded Description Edit
multiprocessing.diff mishok13, 2008-06-26 10:07
Messages (5)
msg68771 - (view) Author: Andrii V. Mishkovskyi (mishok13) Date: 2008-06-26 09:53
multiprocessing.sharedctypes.Array and
multiprocessing.sharedctypes.Value if used according to documentation
fail with AssertionError.

Python 3.0b1+ (py3k:64518, Jun 25 2008, 12:52:38)
[GCC 4.2.3 (Ubuntu 4.2.3-2ubuntu7)] on linux2
Type "help", "copyright", "credits" or "license" for more information.
>>> from multiprocessing import sharedctypes
>>> sharedctypes.Array('i', 1, lock=True)
Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
  File "/usr/local/lib/python3.0/multiprocessing/sharedctypes.py", line
88, in Array
assert hasattr(lock, 'acquire')
AssertionError
>>> sharedctypes.Array('i', 1, lock=False)
Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
  File "/usr/local/lib/python3.0/multiprocessing/sharedctypes.py", line
88, in Array
assert hasattr(lock, 'acquire')
AssertionError
>>> sharedctypes.Array('i', 1, lock=None)
<SynchronizedArray wrapper for
<multiprocessing.sharedctypes.c_long_Array_1 object at 0x83214f4>>
>>> Value('i', lock=True)
Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
  File "/usr/local/lib/python3.0/multiprocessing/__init__.py", line 246,
in Value
return Value(typecode_or_type, *args, **kwds)
  File "/usr/local/lib/python3.0/multiprocessing/sharedctypes.py", line
75, in Value
assert hasattr(lock, 'acquire')
AssertionError

The same goes for multiprocessing.Array and multiprocessing.Value.

Comparing code to documentation it's obvious that lock argument can be
one of Lock, RLock or None objects (or any object with "acquire"
attribute), but not True or False. Also, looking at the code it seems
strange to me that 'lock' is a keyword-only argument. Why not use simple
default argument "lock=None" for Array() function?
Proposed patch tries to address these issues.
msg68772 - (view) Author: Andrii V. Mishkovskyi (mishok13) Date: 2008-06-26 10:07
And here is the patch itself. :)
msg77121 - (view) Author: Santiago Gala (sgala) Date: 2008-12-06 13:24
Note that if the error is in the documentation semantics, and not in the
implementation, then the benchmark code in the documentation is also
broken, and should be change to not use lock=True/False respectively...

I'm not sure if the patch here is good or rather lock=True/False should
be the right API and the implementation should be changed along this lines:

diff --git a/Lib/multiprocessing/sharedctypes.py
b/Lib/multiprocessing/sharedctypes.py
index b94cd52..2f68e74 100644
--- a/Lib/multiprocessing/sharedctypes.py
+++ b/Lib/multiprocessing/sharedctypes.py
@@ -79,10 +79,11 @@ def Array(typecode_or_type, size_or_initializer,
**kwds):
     if kwds:
         raise ValueError('unrecognized keyword argument(s): %s' %
list(kwds.keys()))
     obj = RawArray(typecode_or_type, size_or_initializer)
-    if lock is None:
+    if lock is True:
         lock = RLock()
-    assert hasattr(lock, 'acquire')
-    return synchronized(obj, lock)
+        return synchronized(obj, lock)
+    return obj
+    
 
 def copy(obj):
     new_obj = _new_value(type(obj))
msg77123 - (view) Author: Santiago Gala (sgala) Date: 2008-12-06 13:31
oops, there is a proper code patch in issue4449 , and the documentation
is right.
msg77319 - (view) Author: Jesse Noller (jnoller) * (Python committer) Date: 2008-12-08 16:14
Dupe, issue4449
History
Date User Action Args
2022-04-11 14:56:35adminsetgithub: 47456
2008-12-08 17:03:05amaury.forgeotdarcsetsuperseder: AssertionError in Doc/includes/mp_benchmarks.py
2008-12-08 16:14:00jnollersetmessages: + msg77319
2008-12-08 16:13:53jnollersetstatus: open -> closed
resolution: duplicate
2008-12-06 13:31:46sgalasetmessages: + msg77123
2008-12-06 13:24:44sgalasetnosy: + sgala
messages: + msg77121
2008-06-26 12:53:08benjamin.petersonsetassignee: georg.brandl -> jnoller
2008-06-26 10:08:01mishok13setfiles: + multiprocessing.diff
keywords: + patch
messages: + msg68772
2008-06-26 09:58:38mishok13setassignee: georg.brandl
components: + Documentation
nosy: + georg.brandl
2008-06-26 09:53:16mishok13create