首頁(yè) 猿問為什么這個(gè)數(shù)組值被刪除，但仍然打??？

Python

HUH函數(shù) 2022-09-27 15:09:38

這個(gè)腳本是我擁有的一個(gè)更大的腳本的非常簡(jiǎn)單的版本，我在這里做的事情是刪除“pip”，如果有這樣的數(shù)組值。但是當(dāng)?shù)诙€(gè)周期到來(lái)時(shí)（甚至更多），pip繼續(xù)在屏幕上打印，我不想這樣做。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貢獻(xiàn)1780條經(jīng)驗(yàn) 獲得超4個(gè)贊

您需要在多線程代碼中進(jìn)行一些可靠的并發(fā)控制，您需要確保按順序發(fā)生一些事情：

您需要確保隊(duì)列不會(huì)再次讀取列表，直到線程從隊(duì)列中插入的第一輪中清除為止。pip
您需要確保線程不會(huì)同時(shí)改變相同的元素，這將導(dǎo)致其中一個(gè)線程引發(fā)異常，即它無(wú)法刪除已刪除的元素。

你可以利用在多線程程序的流上放置一些控制，讓我們聲明一個(gè)名為的事件，Queue 將等待這個(gè)事件得到滿足，以便它開始其第二次迭代，以查詢列表的所有元素。該事件將在成功從列表中刪除 pip 后由您的一個(gè)線程設(shè)置。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()

讓我們?cè)囋囘@個(gè)：

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