prologic/test_map.py

## test_map.py
#!/usr/bin/env python


"""Bridge Example

A Bridge example ...
"""


from __future__ import print_function

import sys
from time import sleep
from itertools import repeat
from operator import attrgetter


from circuits import child, Event, Component, Debugger


class main(Event):
    """main Event"""


class isprime(Event):
    """isprime Event"""


class emap(Event):
    """emap Event"""


class Worker(Component):

    def isprime(self, x):
        sleep(0.1)
        if x in [0, 1]:
            return False
        for n in xrange(2, int(x ** 0.5 + 1)):
            if x % n == 0:
                return False
        return True


getresult = attrgetter("result")
getvalue = attrgetter("value")


class Pool(Component):

    def init(self):
        self.workers = []

    def add(self, worker):
        self.workers.append(worker.start(process=True, link=self))

    def emap(self, event, e, xs):
        vs = []

        while xs:
            for process, worker in self.workers:
                if xs:
                    vs.append(self.fire(child(e(xs.pop())), worker.channel))

        while not all(map(getresult, vs)):
            yield

        yield map(getvalue, vs)


class App(Component):

    def init(self, *args):
        Debugger(events=False).register(self)

        n = args and int(args[0]) or 2

        self.pool = Pool().register(self)

        for _ in repeat(None, n):
            self.pool.add(Worker())

        self.fire(main())

    def main(self):
        xs = yield self.call(emap(isprime, range(100)))
        print(xs)

        raise SystemExit(0)

App(*sys.argv[1:]).run()
	#!/usr/bin/env python


	"""Bridge Example

	A Bridge example ...
	"""


	from __future__ import print_function

	import sys
	from time import sleep
	from itertools import repeat
	from operator import attrgetter


	from circuits import child, Event, Component, Debugger


	class main(Event):
	"""main Event"""


	class isprime(Event):
	"""isprime Event"""


	class emap(Event):
	"""emap Event"""


	class Worker(Component):

	def isprime(self, x):
	sleep(0.1)
	if x in [0, 1]:
	return False
	for n in xrange(2, int(x ** 0.5 + 1)):
	if x % n == 0:
	return False
	return True


	getresult = attrgetter("result")
	getvalue = attrgetter("value")


	class Pool(Component):

	def init(self):
	self.workers = []

	def add(self, worker):
	self.workers.append(worker.start(process=True, link=self))

	def emap(self, event, e, xs):
	vs = []

	while xs:
	for process, worker in self.workers:
	if xs:
	vs.append(self.fire(child(e(xs.pop())), worker.channel))

	while not all(map(getresult, vs)):
	yield

	yield map(getvalue, vs)


	class App(Component):

	def init(self, *args):
	Debugger(events=False).register(self)

	n = args and int(args[0]) or 2

	self.pool = Pool().register(self)

	for _ in repeat(None, n):
	self.pool.add(Worker())

	self.fire(main())

	def main(self):
	xs = yield self.call(emap(isprime, range(100)))
	print(xs)

	raise SystemExit(0)

	App(*sys.argv[1:]).run()