gistfile1.py

import gevent

class Publisher(object):

    def __init__(self):
        self.channels = []
        self.subscribers = []
        self.subscriptions = {}
        self.publications = {}

    def distribute(self, channel):
        def publication():
            for article in channel:
                for sub in self.subscriptions[hash(channel)]:
                    sub.put(article)
        self.publications[hash(channel)] = gevent.spawn(publication)

    def subscribe(self, subscriber, channel):
        if hash(channel) not in self.subscriptions:
            self.subscriptions[hash(channel)] = []
        self.subscriptions[hash(channel)].append(subscriber)