stackless多核测试

nahuat

[color="#8080ff"]#!/usr/bin/pypy-stackless
[color="#8080ff"]# -*- coding: utf8 -*-
[color="#ff40ff"]import stackless, time
c1, c2 = stackless.channel(), stackless.channel()
[color="#ffff00"]def [color="#00ffff"]log(msg):
    t = time.time()
    [color="#ffff00"]print '[color="#ff6060"][%s.%06d]' % (time.strftime('[color="#ff6060"]%T', time.localtime(t)), (t - int(t)) * 1000000), msg
[color="#ffff00"]def [color="#00ffff"]consumer(name, channel):
    log('[color="#ff6060"]entry ' + name)
    log(channel.receive())
    time.sleep(3)
    log('[color="#ff6060"]leave ' + name)
[color="#ffff00"]def [color="#00ffff"]productor():
    log('[color="#ff6060"]entry productor')
    c1.send(('[color="#ff6060"]hello', '[color="#ff6060"]world'))
    c2.send(('[color="#ff6060"]foo bar',))
    log('[color="#ff6060"]leave productor')
stackless.tasklet(productor)()
stackless.tasklet(consumer)('[color="#ff6060"]one', c1)
stackless.tasklet(consumer)('[color="#ff6060"]two', c2)
stackless.run()
"""
[color="#ff6060"]以下是执行结果
[color="#ff6060"][18:28:38.464008] entry productor
[color="#ff6060"][18:28:38.464564] entry one
[color="#ff6060"][18:28:38.464715] ('hello', 'world')
[color="#ff6060"][18:28:41.466892] leave one
[color="#ff6060"][18:28:41.467211] entry two
[color="#ff6060"][18:28:41.467592] ('foo bar',)
[color="#ff6060"][18:28:44.470731] leave two
[color="#ff6060"][18:28:44.471030] leave productor
"""
               
               
               

本文来自ChinaUnix博客，如果查看原文请点：http://blog.chinaunix.net/u/21842/showart_1970592.html