mirror of
https://github.com/python/cpython.git
synced 2025-08-03 00:23:06 +00:00
Merged revisions 75818 via svnmerge from
svn+ssh://pythondev@svn.python.org/python/trunk ........ r75818 | antoine.pitrou | 2009-10-27 18:41:58 +0100 (mar., 27 oct. 2009) | 3 lines Issue #7205: Fix a possible deadlock when using a BZ2File object from several threads at once. ........
This commit is contained in:
parent
495f7b5adb
commit
c66363f5e0
3 changed files with 27 additions and 1 deletions
|
@ -7,6 +7,7 @@ from io import BytesIO
|
|||
import os
|
||||
import subprocess
|
||||
import sys
|
||||
import threading
|
||||
|
||||
# Skip tests if the bz2 module doesn't exist.
|
||||
bz2 = support.import_module('bz2')
|
||||
|
@ -282,6 +283,23 @@ class BZ2FileTest(BaseTest):
|
|||
else:
|
||||
self.fail("1/0 didn't raise an exception")
|
||||
|
||||
def testThreading(self):
|
||||
# Using a BZ2File from several threads doesn't deadlock (issue #7205).
|
||||
data = b"1" * 2**20
|
||||
nthreads = 10
|
||||
f = bz2.BZ2File(self.filename, 'wb')
|
||||
try:
|
||||
def comp():
|
||||
for i in range(5):
|
||||
f.write(data)
|
||||
threads = [threading.Thread(target=comp) for i in range(nthreads)]
|
||||
for t in threads:
|
||||
t.start()
|
||||
for t in threads:
|
||||
t.join()
|
||||
finally:
|
||||
f.close()
|
||||
|
||||
|
||||
class BZ2CompressorTest(BaseTest):
|
||||
def testCompress(self):
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue