Path: csiph.com!eeepc.pasdenom.info!news.pasdenom.info!news.dougwise.org!aioe.org!feeder.news-service.com!news2.euro.net!newsgate.cistron.nl!newsgate.news.xs4all.nl!post.news.xs4all.nl!not-for-mail
Date: Wed, 09 Feb 2011 17:28:55 +0100
From: Jean-Michel Pichavant <jeanmichel@sequans.com>
User-Agent: Mozilla-Thunderbird 2.0.0.24 (X11/20100328)
MIME-Version: 1.0
To: Yang Zhang <yanghatespam@gmail.com>
Subject: Re: Python subprocesses experience mysterious delay in receiving stdin EOF
References: <AANLkTi=D7ySVTesrf2+TBddaNDF=E616ACVeUm5OSwcC@mail.gmail.com>	<4D52037E.4000809@mrabarnett.plus.com> <AANLkTik+kydEJGy1-M3BbwJczxTyA91r3YW0xfWsuko2@mail.gmail.com>
In-Reply-To: <AANLkTik+kydEJGy1-M3BbwJczxTyA91r3YW0xfWsuko2@mail.gmail.com>
Content-Type: text/plain; charset=ISO-8859-1; format=flowed
Content-Transfer-Encoding: 7bit
Cc: python-list@python.org
Precedence: list
Newsgroups: comp.lang.python
Message-ID: <mailman.46.1297268936.1633.python-list@python.org>
Lines: 101
NNTP-Posting-Host: 82.94.164.166
Xref: csiph.com comp.lang.python:55770

Yang Zhang wrote:
> On Wed, Feb 9, 2011 at 11:01 AM, MRAB <python@mrabarnett.plus.com> wrote:
>   
>> On 09/02/2011 01:59, Yang Zhang wrote:
>>     
>>> I reduced a problem I was seeing in my application down into the
>>> following test case. In this code, a parent process concurrently
>>> spawns 2 (you can spawn more) subprocesses that read a big message
>>> from the parent over stdin, sleep for 5 seconds, and write something
>>> back. However, there's unexpected waiting happening somewhere, causing
>>> the code to complete in 10 seconds instead of the expected 5.
>>>
>>> If you set `verbose=True`, you can see that the straggling subprocess
>>> is receiving most of the messages, then waiting for the last chunk of
>>> 3 chars---it's not detecting that the pipe has been closed.
>>> Furthermore, if I simply don't do anything with the second process
>>> (`doreturn=True`), the first process will *never* see the EOF.
>>>
>>> Any ideas what's happening? Further down is some example output.
>>> Thanks in advance.
>>>
>>>     from subprocess import *
>>>     from threading import *
>>>     from time import *
>>>     from traceback import *
>>>     import sys
>>>     verbose = False
>>>     doreturn = False
>>>     msg = (20*4096+3)*'a'
>>>     def elapsed(): return '%7.3f' % (time() - start)
>>>     if sys.argv[1:]:
>>>       start = float(sys.argv[2])
>>>       if verbose:
>>>         for chunk in iter(lambda: sys.stdin.read(4096), ''):
>>>           print>>  sys.stderr, '..', time(), sys.argv[1], 'read',
>>> len(chunk)
>>>       else:
>>>         sys.stdin.read()
>>>       print>>  sys.stderr, elapsed(), '..', sys.argv[1], 'done reading'
>>>       sleep(5)
>>>       print msg
>>>     else:
>>>       start = time()
>>>       def go(i):
>>>         print elapsed(), i, 'starting'
>>>         p = Popen(['python','stuckproc.py',str(i), str(start)],
>>> stdin=PIPE, stdout=PIPE)
>>>         if doreturn and i == 1: return
>>>         print elapsed(), i, 'writing'
>>>         p.stdin.write(msg)
>>>         print elapsed(), i, 'closing'
>>>         p.stdin.close()
>>>         print elapsed(), i, 'reading'
>>>         p.stdout.read()
>>>         print elapsed(), i, 'done'
>>>       ts = [Thread(target=go, args=(i,)) for i in xrange(2)]
>>>       for t in ts: t.start()
>>>       for t in ts: t.join()
>>>
>>> Example output:
>>>
>>>       0.001 0 starting
>>>       0.003 1 starting
>>>       0.005 0 writing
>>>       0.016 1 writing
>>>       0.093 0 closing
>>>       0.093 0 reading
>>>       0.094 1 closing
>>>       0.094 1 reading
>>>       0.098 .. 1 done reading
>>>       5.103 1 done
>>>       5.108 .. 0 done reading
>>>      10.113 0 done
>>>
>>>       
>> I changed 'python' to the path of python.exe and 'stuckproc.py' to its
>> full path and tried it with Python 2.7 on Windows XP Pro. It worked as
>> expected.
>>     
>
> Good point - I didn't specify that I'm seeing this on Linux (Ubuntu
> 10.04's Python 2.6).
>
>   
python test.py  
  0.000 0 starting
  0.026 0 writing
  0.026 0 closing
  0.026 0 reading
  0.029 .. 0 done reading
  0.030 1 starting
  0.038 1 writing
  0.058 1 closing
  0.058 1 reading
  0.061 .. 1 done reading
  5.026 0 done
  5.061 1 done

on debian lenny (Python 2.5)

JM