多线程-管理事务和处理顺序

你好呀 问题:我正在寻找信息 /模式 /食谱 实施多线程程序(多个生产者 /消费者) 这将管理交易并维护不同的序列 线程. 背景: 我正忙着写一个适配器,从IBM WebSphere MQ中获取消息 PYMQI并将这些消息插入数据库(在某些之后 处理,消息以XML为单位). 如果我评论数据库 ..执行该代码,我每秒处理数百条消息, 数据库将整个过程减少到大约60-100条消息 第二. 我希望通过有两个线程阅读 来自MQ的消息,另一个填充数据库的消息 - 至少然后 数据库位永远不必等待我获取另一个 信息. (我正在考虑稍后添加第二个线程 也). 挑战是需要精确处理这些消息 序列和交易. (即获取消息的线程 将不得不等待确认消息已成功 在进行交易之前已插入数据库中,在MQ中 术语该消息只会真正删除.) 我已经开始使用词典实现一种状态计算机 促进这一点,但我现在担心 - 有一个更好的方法 - 我可能会被字典处理更新 /设置咬伤 值不一定是线程安全的. 我已经看了这个食谱http://aspn.activestate.com/aspn/coo.../recipe/302997 可能替代字典,但我什至不确定我是否正在使用 正确. 谢谢你 jaco

标签: python

添加新评论