Как Вы реализовали бы основной цикл событий?

Обычно я делал бы это со своего рода семафор подсчета :

1. Семафор запускается в нуле.
2. Цикл событий ожидает на семафоре.
3. Событие (события) входит, семафор увеличен.
4. Обработчик событий разблокирует и постепенно уменьшает семафор и обрабатывает событие.
5. , Когда все события обрабатываются, семафор является блоками нулевого и цикла событий снова.

, Если Вы не хотите добираться, который усложнил, Вы могли просто добавить сон () вызов в Вашем цикле с условием продолжения с тривиально маленьким временем сна. Это заставит Ваше сообщение, обрабатывающее поток уступать, это - процессорное время к другим потокам. ЦП больше не будет привязан в 100%, но это все еще довольно расточительно.

Python:

можно посмотреть на реализацию Скрученный реактор , который является, вероятно, лучшей реализацией для цикла событий в Python. Реакторы в Скрученном являются реализациями интерфейса, и можно определить реактор типа для выполнения: выберите, epoll, kqueue (все на основе c API с помощью тех системных вызовов), существуют также реакторы на основе QT и инструментариев GTK.

А простая реализация должна была бы использовать выбор:

#echo server that accepts multiple client connections without forking threads

import select
import socket
import sys

host = ''
port = 50000
backlog = 5
size = 1024
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server.bind((host,port))
server.listen(backlog)
input = [server,sys.stdin]
running = 1

#the eventloop running
while running:
    inputready,outputready,exceptready = select.select(input,[],[])

    for s in inputready:

        if s == server:
            # handle the server socket
            client, address = server.accept()
            input.append(client)

        elif s == sys.stdin:
            # handle standard input
            junk = sys.stdin.readline()
            running = 0

        else:
            # handle all other sockets
            data = s.recv(size)
            if data:
                s.send(data)
            else:
                s.close()
                input.remove(s)
server.close() 

Я пользовался бы простой, легкой библиотекой обмена сообщениями под названием ZeroMQ ( http://www.zeromq.org/ ). Это - библиотека с открытым исходным кодом (LGPL). Это - очень небольшая библиотека; на моем сервере целый проект компилирует приблизительно за 60 секунд.

ZeroMQ чрезвычайно упростит Ваш событийно-ориентированный код, И это - также наиболее эффективное решение с точки зрения производительности. При передаче между использованием потоков ZeroMQ намного быстрее (с точки зрения скорости), чем использование семафоров или локальных сокетов UNIX. ZeroMQ также быть 100%-м портативным решением, тогда как все другие решения привязали бы Ваш код к определенной операционной системе.