Web编程中的Python线程

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了Web编程中的Python线程，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1644字，纯文字阅读大概需要3分钟。

内容图文

我在Web应用程序中面临潜在的竞争状况：

# get the submissions so far from the cache
submissions = cache.get('user_data')
# add the data from this user to the local dict
submissions[user_id] = submission

# update the cached dict on server
submissions = cache.update('user_data', submissions)

if len(submissions) == some_number:
    ...

逻辑很简单,我们首先获取存储在Web服务器缓存中的共享字典,将提交内容(由每个请求发送到服务器)添加到其本地副本中,然后通过使用此更新的本地替换它来更新缓存的副本复制.最后,如果我们收到一定数量的数据,我们将做其他事情.注意

submissions = cache.update('user_data', submissions)

将从缓存中返回字典的最新副本,即新近更新的副本.

因为服务器可以同时服务多个请求(每个请求都在其自己的线程中),并且所有这些线程都如上所述访问高速缓存中的共享字典,因此会产生潜在的竞争条件.

我想知道,在Web编程的上下文中,如何在不牺牲过多性能的情况下,如何有效地处理线程以防止出现这种特殊情况下的争用情况.一些代码示例将不胜感激.

解决方法:

我的首选解决方案是拥有一个修改提交字典的线程和一个供该线程使用的队列.如果您偏执狂,甚至可以公开有关提交指令的只读视图.使用队列和使用者模式,锁定不会有问题.

当然,这假设您有一个Web框架可以让您创建该线程.

编辑：多进程不是一个好建议；删除.

编辑：这种事情在Python中真的很简单：

import threading, Queue

Stop = object()

def consumer(real_dict, queue):
    while True:
        try:
            item = queue.get(timeout=100)
            if item == Stop:
                break
            user, submission = item
            real_dict[user] = submission
        except Queue.Empty:
            continue

q = Queue.Queue()
thedict={}

t = threading.Thread(target=consumer, args=(thedict,q,))
t.start()

然后,您可以尝试：

>>> thedict
{}
>>> q.put(('foo', 'bar'))
>>> thedict
{'foo': 'bar'}
>>> q.put(Stop)
>>> q.put(('baz', 'bar'))
>>> thedict
{'foo': 'bar'}

内容总结

以上是互联网集市为您收集整理的Web编程中的Python线程全部内容，希望文章能够帮你解决Web编程中的Python线程所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端