Многопроцессорность и сокеты в Python

Я пытаюсь совместить многопроцессорность и программирование сокетов, но на этом я застрял. Проблема в том, что я получаю эту ошибку:

  File "multiprocesssockserv.py", line 11, in worker
    clientsocket = socket.fromfd(clientfileno, socket.AF_INET, socket.SOCK_STREAM)
error: [Errno 9] Bad file descriptor

Полный код, вызывающий ошибку, выглядит следующим образом:

import multiprocessing as mp
import logging
import socket

logger = mp.log_to_stderr(logging.WARN)

def worker(queue):
    while True:
        clientfileno = queue.get()
        print clientfileno
        clientsocket = socket.fromfd(clientfileno, socket.AF_INET, socket.SOCK_STREAM)
        clientsocket.recv()
        clientsocket.send("Hello World")
        clientsocket.close()

if __name__ == '__main__':
    num_workers = 5
    socket_queue = mp.Queue()
    workers = [mp.Process(target=worker, args=(socket_queue,)) for i in
            range(num_workers)]

    for p in workers:
        p.daemon = True
        p.start()

    serversocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    serversocket.bind(('',9090))
    serversocket.listen(5)
    while True:
        client, address = serversocket.accept()
        socket_queue.put(client.fileno())

edit: Я использую socket.fromfd, потому что я не могу поместить сокеты в очередь :) Мне нужен способ как-то получить доступ к одним и тем же сокетам из разных процессов. В этом суть моей проблемы.

5
задан yasar 17 December 2011 в 14:11
поделиться