微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

列表是线程安全的吗?

如何解决列表是线程安全的吗?

| 我注意到,通常建议使用具有多个线程的队列,而不是列表和“ 0”。这是因为列表不是线程安全的,还是出于其他原因?     

解决方法

        列表本身是线程安全的。在CPython中,GIL防止对它们的并发访问,而其他实现则请小心地为它们的列表实现使用细粒度锁或同步数据类型。但是,虽然列表本身不会因尝试并发访问而损坏,但列表的数据不受保护。例如:
L[0] += 1
如果另一个线程做同样的事情,则不能保证实际上将L [0]增加1,因为
+=
不是原子操作。 (实际上,Python中很少有原子操作的操作,因为大多数操作会导致调用任意Python代码。)您应该使用Queues,因为如果您仅使用不受保护的列表,则可能由于种族而获得或删除了错误的项目条件。     ,        为了阐明托马斯出色答案中的观点,应该提到“ 3”是线程安全的。 这是因为不必担心一旦我们去写入数据,读取的数据就会位于同一位置。 “ 3”操作不读取数据,仅将数据写入列表。     ,        这是“ 5”操作示例以及它们是否是线程安全的示例的完整而详尽的列表。 希望在这里获得有关“ 6”语言构造的答案。     ,        最近,我遇到这种情况,我需要在一个线程中连续地追加到列表,循环遍历这些项目,并检查该项目是否准备就绪,在我的情况下,它是一个AsyncResult,只有在准备就绪时才将其从列表中删除。  我找不到任何可以清楚说明我的问题的例子  这是一个示例,演示了在一个线程中连续添加到列表,并在另一个线程中连续从同一列表中删除  有缺陷的版本可以在较小的数字上轻松运行,但是将数字保持足够大并运行几次,您将看到错误 FLAWED版本
import threading
import time

# Change this number as you please,bigger numbers will get the error quickly
count = 1000
l = []

def add():
    for i in range(count):
        l.append(i)
        time.sleep(0.0001)

def remove():
    for i in range(count):
        l.remove(i)
        time.sleep(0.0001)


t1 = threading.Thread(target=add)
t2 = threading.Thread(target=remove)
t1.start()
t2.start()
t1.join()
t2.join()

print(l)
错误时输出
Exception in thread Thread-63:
Traceback (most recent call last):
  File \"/Users/zup/.pyenv/versions/3.6.8/lib/python3.6/threading.py\",line 916,in _bootstrap_inner
    self.run()
  File \"/Users/zup/.pyenv/versions/3.6.8/lib/python3.6/threading.py\",line 864,in run
    self._target(*self._args,**self._kwargs)
  File \"<ipython-input-30-ecfbac1c776f>\",line 13,in remove
    l.remove(i)
ValueError: list.remove(x): x not in list
使用锁的版本
import threading
import time
count = 1000
l = []
r = threading.RLock()
def add():
    r.acquire()
    for i in range(count):
        l.append(i)
        time.sleep(0.0001)
    r.release()

def remove():
    r.acquire()
    for i in range(count):
        l.remove(i)
        time.sleep(0.0001)
    r.release()


t1 = threading.Thread(target=add)
t2 = threading.Thread(target=remove)
t1.start()
t2.start()
t1.join()
t2.join()

print(l)
输出量
[] # Empty list
结论 正如前面的答案中提到的,从列表本身追加或弹出元素的行为是线程安全的,而在一个线程中追加并在另一个线程中弹出时,不是线程安全的     

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