title: Python Multiprocessing: Broken Pipe exception after increasing Pool size
body: <p>The exception I get. All I did that I increased pool count</p>
  
  <p><strong>Code</strong></p>
  
  <pre><code> def parse(url):
    r = request.get(url)
  POOL_COUNT = 75
  with Pool(POOL_COUNT) as p:
      result = p.map(parse, links)
  
  
  
  File "/usr/lib64/python3.5/multiprocessing/pool.py", line 130, in worker
      put((job, i, (False, wrapped)))
    File "/usr/lib64/python3.5/multiprocessing/queues.py", line 355, in put
      self._writer.send_bytes(obj)
    File "/usr/lib64/python3.5/multiprocessing/connection.py", line 200, in send_bytes
      self._send_bytes(m[offset:offset + size])
    File "/usr/lib64/python3.5/multiprocessing/connection.py", line 404, in _send_bytes
      self._send(header + buf)
    File "/usr/lib64/python3.5/multiprocessing/connection.py", line 368, in _send
      n = write(self._handle, buf)
  BrokenPipeError: [Errno 32] Broken pipe
  Process ForkPoolWorker-26:
  Traceback (most recent call last):
    File "/usr/lib64/python3.5/multiprocessing/pool.py", line 125, in worker
      put((job, i, result))
    File "/usr/lib64/python3.5/multiprocessing/queues.py", line 355, in put
      self._writer.send_bytes(obj)
    File "/usr/lib64/python3.5/multiprocessing/connection.py", line 200, in send_bytes
      self._send_bytes(m[offset:offset + size])
    File "/usr/lib64/python3.5/multiprocessing/connection.py", line 404, in _send_bytes
      self._send(header + buf)
    File "/usr/lib64/python3.5/multiprocessing/connection.py", line 368, in _send
      n = write(self._handle, buf)
  BrokenPipeError: [Errno 32] Broken pipe
  </code></pre>