o0神秘嘉宾0o 发表于 2023-9-8 01:21:18

各位大佬,实在想不出来了,函数值赋给列表的问题,哪位大佬帮忙给看一下,跪谢

import threading
from pynput.mouse import Listener

x_list = []
y_list = []

def on_click(x, y, button, pressed):
    global x_list,y_list
    print("鼠标位置为:{},执行操作为:{},是否点击或松开:{}".format((x, y), button, pressed))
    if pressed == True:
      x_list.append(x)
      y_list.append(y)
      print(x_list)
def ls_k_thread():
    with Listener(on_click=on_click) as listener:
      listener.join()

def analyse_pic_thread():
    r = threading.Thread(target=ls_k_thread)
    r.start()
analyse_pic_thread()

print(x_list)
"C:\Users\Ace\Desktop\YT(JHQUM%5BUH{F9$T0A}AD%5DM.png"

isdkz 发表于 2023-9-8 01:21:36

问题的关键在于线程的执行顺序。在你的代码中,主线程会立即打印 x_list ,但是 x_list 在子线程中被修改,所以打印出来的结果是空列表。解决这个问题的一种方法是使用线程同步机制,确保子线程执行完毕后再打印 x_list 。

可以使用 threading.Event 来实现线程同步。下面是修改后的代码:

import threading
from pynput.mouse import Listener

x_list = []
y_list = []
event = threading.Event()

def on_click(x, y, button, pressed):
    global x_list, y_list
    print("鼠标位置为:{},执行操作为:{},是否点击或松开:{}".format((x, y), button, pressed))
    if pressed == True:
      x_list.append(x)
      y_list.append(y)
      print(x_list)

      # 通知主线程子线程执行完毕
      event.set()

def ls_k_thread():
    with Listener(on_click=on_click) as listener:
      listener.join()

def analyse_pic_thread():
    r = threading.Thread(target=ls_k_thread)
    r.start()

# 启动子线程
analyse_pic_thread()

# 等待子线程执行完毕
event.wait()

# 打印结果
print(x_list)


这样修改后,主线程会等待子线程执行完毕后再打印 x_list ,确保打印的结果是子线程修改后的列表。

Mike_python小 发表于 2023-9-8 01:21:41

关于函数值赋给列表的问题

您的代码存在一个问题:在主线程打印 x_list 的时候,可能会出现列表为空的情况。这是因为 on_click 函数运行在一个单独的线程中,并且在主线程打印 x_list 之前,子线程没有足够的时间将数据添加到列表中。

解决这个问题的方法是,使用互斥锁(mutex lock)来确保在访问共享的 x_list 和 y_list 时的线程安全。

下面是修改后的代码:


import threading
from pynput.mouse import Listener

x_list = []
y_list = []
mutex = threading.Lock()# 创建互斥锁

def on_click(x, y, button, pressed):
    global x_list, y_list
    print("鼠标位置为:{}, 执行操作为:{}, 是否点击或松开:{}".format((x, y), button, pressed))
   
    if pressed:
      mutex.acquire()# 获取锁
      try:
            x_list.append(x)
            y_list.append(y)
            print(x_list)
      finally:
            mutex.release()# 释放锁

def ls_k_thread():
    with Listener(on_click=on_click) as listener:
      listener.join()

def analyse_pic_thread():
    r = threading.Thread(target=ls_k_thread)
    r.start()

analyse_pic_thread()

# 主线程暂时休眠1秒钟,以等待子线程将数据添加到列表中
time.sleep(1)

# 打印结果(注意:子线程可能仍在运行,列表可能会继续增加)
print(x_list)


在上述代码中,我们添加了一个互斥锁 mutex,并在访问 x_list 和 y_list 时使用 mutex.acquire() 获取锁,在访问结束后使用 mutex.release() 释放锁。这样可以确保在修改列表时只有一个线程进行操作,从而避免了数据竞争和不一致的问题。

另外,在主线程打印 x_list 前,我们使用 time.sleep(1) 让主线程暂停1秒钟,以等待子线程将数据添加到列表中。

希望以上修改能够解决您的问题。如果还有其他问题,请随时提问。

球一个最佳答案谢谢啦!这对我非常重要!{:10_254:}{:10_254:}{:10_254:}
页: [1]
查看完整版本: 各位大佬,实在想不出来了,函数值赋给列表的问题,哪位大佬帮忙给看一下,跪谢