当前位置：文江博客话题详情

从不同线程读取数据可能会出现错误

发布于 2024-10-30 05:49:47 字数 217 浏览 1 评论 0原文

我目前正在编写一个使用多线程的程序。为了能够在这些线程之间共享数据，我使用像 threading.Lock 这样的锁来避免运行期间的访问问题。

但我遇到的问题是，我必须为每个数据创建大量锁才能读取该数据。即使我对数据进行“分组”并为它们使用相同的锁，它们也太多了。

所以我问自己：如果一个线程只读取数据而不更改它（这也适用于所有其他线程），是否会发生任何问题？

提前致谢，

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

忆伤 2024-11-06 05:49:47

如果所有线程都只是读取数据，那么从不同线程同时访问数据就没有问题，只要读取数据不会改变它即可。更改读取的数据可能会发生在某些数据结构中，defaultdict这是一个棘手的例子。

如果您有消费者\生产者场景，请考虑使用 Queue.Queue，一个线程安全的数据结构，允许同时读取和写入。来自 Python 文档：

def worker():
    while True:
        item = q.get()
        do_work(item)
        q.task_done()

q = Queue()
for i in range(num_worker_threads):
     t = Thread(target=worker)
     t.daemon = True
     t.start()

for item in source():
    q.put(item)

q.join()       # block until all tasks are done

If all your threads just read data, there is no problem accessing the data simultaneously from different threads, as long as reading the data does not change it. Changing the read data can occur in some data structure, defaultdict being a tricky example.

If you have a consumer\producer scenario, consider using Queue.Queue, a thread-safe data structure which allows simultaneous reads and writes. From the Python documentation:

def worker():
    while True:
        item = q.get()
        do_work(item)
        q.task_done()

q = Queue()
for i in range(num_worker_threads):
     t = Thread(target=worker)
     t.daemon = True
     t.start()

for item in source():
    q.put(item)

q.join()       # block until all tasks are done

回复收藏 0 原文