Show More
@@ -13,6 +13,7 b'' | |||||
13 |
|
13 | |||
14 | import os |
|
14 | import os | |
15 | import shutil |
|
15 | import shutil | |
|
16 | import sys | |||
16 | import tempfile |
|
17 | import tempfile | |
17 |
|
18 | |||
18 | from Queue import Empty |
|
19 | from Queue import Empty | |
@@ -124,6 +125,7 b' def test_simple_print():' | |||||
124 | print ('hello') |
|
125 | print ('hello') | |
125 |
|
126 | |||
126 |
|
127 | |||
|
128 | @dec.knownfailureif(sys.platform == 'win32', "subprocess prints fail on Windows") | |||
127 | def test_subprocess_print(): |
|
129 | def test_subprocess_print(): | |
128 | """printing from forked mp.Process""" |
|
130 | """printing from forked mp.Process""" | |
129 | with new_kernel() as km: |
|
131 | with new_kernel() as km: | |
@@ -162,7 +164,7 b' def test_subprocess_noprint():' | |||||
162 | np = 5 |
|
164 | np = 5 | |
163 | code = '\n'.join([ |
|
165 | code = '\n'.join([ | |
164 | "import multiprocessing as mp", |
|
166 | "import multiprocessing as mp", | |
165 | "pool = [mp.Process(target=range,args=(i,)) for i in range(%i)]" % np, |
|
167 | "pool = [mp.Process(target=range, args=(i,)) for i in range(%i)]" % np, | |
166 | "for p in pool: p.start()", |
|
168 | "for p in pool: p.start()", | |
167 | "for p in pool: p.join()" |
|
169 | "for p in pool: p.join()" | |
168 | ]) |
|
170 | ]) | |
@@ -176,6 +178,7 b' def test_subprocess_noprint():' | |||||
176 | _check_mp_mode(km, expected=False, stream="stderr") |
|
178 | _check_mp_mode(km, expected=False, stream="stderr") | |
177 |
|
179 | |||
178 |
|
180 | |||
|
181 | @dec.knownfailureif(sys.platform == 'win32', "subprocess prints fail on Windows") | |||
179 | def test_subprocess_error(): |
|
182 | def test_subprocess_error(): | |
180 | """error in mp.Process doesn't crash""" |
|
183 | """error in mp.Process doesn't crash""" | |
181 | with new_kernel() as km: |
|
184 | with new_kernel() as km: |
General Comments 0
You need to be logged in to leave comments.
Login now