阅读量:0
在Python中,可以使用threading
模块来实现多线程数据共享。具体步骤如下:
导入
threading
模块:import threading
定义一个全局变量来共享数据。
创建一个锁对象:
lock = threading.Lock()
。这个锁对象用来控制对共享数据的访问。定义一个线程函数,其中需要对共享数据进行读写操作。
在线程函数中使用锁对象来获取锁,进入临界区。
对共享数据进行读写操作。
释放锁,退出临界区。
下面是一个示例代码:
import threading # 全局变量 shared_data = [] # 创建锁对象 lock = threading.Lock() # 定义线程函数 def thread_func(): global shared_data for i in range(10): # 获取锁,进入临界区 lock.acquire() # 对共享数据进行读写操作 shared_data.append(i) # 释放锁,退出临界区 lock.release() # 创建线程 thread1 = threading.Thread(target=thread_func) thread2 = threading.Thread(target=thread_func) # 启动线程 thread1.start() thread2.start() # 等待线程结束 thread1.join() thread2.join() # 打印共享数据 print(shared_data)
在上面的示例中,两个线程并发地对shared_data
进行写操作,使用锁对象来实现对共享数据的互斥访问。最后打印出的shared_data
列表中应该包含了两个线程各自写入的数据。