首页猿问为什么这个数组值被删除，但仍然打印？

为什么这个数组值被删除，但仍然打印？

Python

HUH函数 2022-09-27 15:09:38

这个脚本是我拥有的一个更大的脚本的非常简单的版本，我在这里做的事情是删除“pip”，如果有这样的数组值。但是当第二个周期到来时（甚至更多），pip继续在屏幕上打印，我不想这样做。import requests, threading, random, string, json, time, queue, renum_worker_threads = int(input("Threads: "))lista = ['asd', 'asdjk', 'pip', 'lasd', 'lol']print(str(lista))def do_work(i): try: print(i.strip()) print(str(lista)) if i == "pip": lista.remove("pip") except Exception as e: print(e)def worker(): while True: item = q.get() if item is not None: do_work(item) q.task_done()q = queue.Queue()threads = []for i in range(num_worker_threads): t = threading.Thread(target=worker) t.start() threads.append(t)for i in range(2): # I have only put 2 cycles for line in lista: q.put(line)q.join()for i in range(num_worker_threads): q.put(None)for t in threads: t.join()

查看完整描述

2 回答

Helenr

TA贡献1780条经验获得超3个赞

您需要在多线程代码中进行一些可靠的并发控制，您需要确保按顺序发生一些事情：

您需要确保队列不会再次读取列表，直到线程从队列中插入的第一轮中清除为止。pip
您需要确保线程不会同时改变相同的元素，这将导致其中一个线程引发异常，即它无法删除已删除的元素。

你可以利用在多线程程序的流上放置一些控制，让我们声明一个名为的事件，Queue 将等待这个事件得到满足，以便它开始其第二次迭代，以查询列表的所有元素。该事件将在成功从列表中删除 pip 后由您的一个线程设置。Eventfirst_iteration_processsed

代码示例：

import requests, threading, random, string, json, time, queue, re

from threading import Event

num_worker_threads = int(input("Threads: "))

lista = ['asd', 'asdjk', 'pip', 'lasd', 'lol']

print(str(lista))

iteration_processsed = Event()

iteration_processsed.set()

def do_work(i):

# global lista

try:

print(i.strip())

print(str(lista))

if i == "pip":

lista.remove("pip")

print("Removed pip successfully")

if i == "iter_end":

iteration_processsed.set()

except Exception as e:

print(e)

def worker():

while True:

item = q.get()

if item is not None:

do_work(item)

q.task_done()

q = queue.Queue()

threads = []

for i in range(num_worker_threads):

t = threading.Thread(target=worker)

t.start()

threads.append(t)

for i in range(3): # I have only put 2 cycles

iteration_processsed.wait()

print(f"Iteration {i} started")

iteration_processsed.clear()

for line in lista:

q.put(line)

q.put('iter_end')

q.join()

for i in range(num_worker_threads):

q.put(None)

for t in threads:

t.join()

让我们试试这个：

Threads: 2

['asd', 'asdjk', 'pip', 'lasd', 'lol']

Iteration 0 started

asd

['asd', 'asdjk', 'pip', 'lasd', 'lol']

asdjk

['asd', 'asdjk', 'pip', 'lasd', 'lol']

pip

['asd', 'asdjk', 'pip', 'lasd', 'lol']

Removed pip successfully

lasd