支持参与者提供并发收件箱处理

caine的Python项目详细描述


凯恩
=


ne import supportingactor

ene."

我男演员的收件箱里有好几年了。
我的演员。收件箱。放("她才16岁!")
my_actor.inbox.put("没有多少人知道这一点!")

告诉我的演员,当收件箱为空时,它就完成了。
我的演员.cut()

output

迈克尔说,"她才16岁!"
迈克尔说,"没有多少人知道这一点!"
结束场景。

演员属性:
等待秒=随机。randint(1,5)
时间。睡眠(等待秒)
打印"演员";%s等待%s秒说,"%s"(演员属性["演员id",等待秒,消息)

创建有3个演员的我的演员back=end-scene,num=num-actor s)



my cucast()



xrange(10):
my cucast.inbox.put("我收到了消息,"%s!"%(i))




输出
-
actor等了2秒说"我收到了消息0。"



my cucast.cast.cut



/>演员0等了1秒钟说:"我去短信息3。1等5秒说"我收到信息1"。2等5秒说"我收到信息2"。2等5秒说"我收到信息2"。0等3秒说"我收到信息4"。1等2秒说"我收到信息5"。1等2秒说"我收到信息5。5秒说"我收到信息5"。1等2秒说"我收到信息5"。1等2秒说"我收到信息5"。1等2秒说"我收到信息5"。1等2秒说"我收到信息5"。1等2秒说"我收到信息5。1等2秒说"我收到信息5"。1等2秒说"我收到信息5。1等2秒说"我收到信息5。5。"演员2等了2秒钟说:"我消息6。0等待3秒说"我收到消息7"。0等待2秒说"我收到消息9"。2等待2秒说"我收到消息9"。1等待2秒说"我收到消息8"。1等待2秒说"我收到消息8"1等待2秒说"我收到消息8。结束场景。




~~~~~~~~~

来自凯恩进口公司Tor

一个综合新消息和先前消息的函数选择的赔率为无:
收集的赔率=[]

打印偶数
如果新的赔率为%2==0:
打印"我得到了偶数%s"%(新的赔率)

将奇数附加到收集的赔率
否则:
收集的赔率。附加(新的赔率)

使用print_偶数collect_odd
并在成功完成时执行print_collected
my_collector=collector(collect=print_偶数collect_odd,callback=print_collected)






对于我在xrange(10):

>我的收藏收藏收藏收藏收藏(inbox.colcollector.inbox.put)中的收藏(i)



>我的收藏收藏收藏(collector.cut)

我得到了偶数:0
;;我得到了偶数:2
我得到了偶数:4
;;我得到了偶数:6

我得到了偶数:8
我收集了这些奇数:[1、3、5、7、9]


cs=random.randint(1,max_wait)
time.sleep(wait_secs)
print'actor_%s等待%s秒说,"%s"%(actor_attributes['actor_id',wait_secs,message)

my戋cast=supportingcast(receive=wait戋rand戋deliver,callbackback=end戋scene,num=3)

My_cast.inbox.put("我及时收到了这封邮件,可以说出来!")

my_cast()

nbox.put("我没有及时收到这条消息来说它!")


演员0等了4秒才说:"我及时收到消息说出来了!"
演员1等了4秒钟才说,"我及时收到消息说出来了!"

将演员添加到演员阵容

演员阵容从两个演员开始或"id"]<;原始演员计数:
打印"我是原始演员中的演员!"我收到消息%s'%(消息编号)
否则:
打印"我是稍后创建的演员!"我收到消息%s%(消息编号)

o my_cast
my_cast.add(add_actor_count)


对于x范围内的i(原始演员计数、原始演员计数+add_actor_count):
my_cast.inbox.put(i)


my_cast.cut()

输出
-
我是原始演员中的演员!我收到消息,我是原剧组的演员!我收到消息1,我是后来创作的演员!我收到消息2,我是后来创作的演员!我收到消息3,我是后来创作的演员!我收到消息4结束场景。

欢迎加入QQ群-->: 979659372 Python中文网_新手群

推荐PyPI第三方库


热门话题
java如何使用Spring和JSF向客户端授予临时权限   java除了Array/ArrayList之外,还有其他保存矩阵元素的方法吗   java BeanValidation不适用于单选按钮   通过java程序连接到配置单元数据库时出错   java如何使用maven解决二级依赖关系   JfreeChart/Java中带有图例的数据表   合并数组时发生java运行时错误   安全性如何在JavaEE中保护WebSocket端点?   java有没有一种方法可以使用insert方法为树插入值   java编程“静态”的另一种方式:代码可以吗?   java阅读文本文件时如何跳过3行   %04X在C中的含义以及如何在java中编写   java我如何验证一个方法不是仅在一个测试范围内对模拟调用的?   java如何在mac中使用启动appium desktop 1.6.1。球棒   仅匹配最多10位小数的java正则表达式