Python多线程如何共享数据 Python多线程数据安全传递方案

<pre class="brush:php;toolbar:false;">import threading
<p>counter = 0
lock = threading.Lock()</p><p>def increment():
global counter
for _ in range(100000):
with lock:
counter += 1</p><p>threads = [threading.Thread(target=increment) for _ in range(5)]
for t in threads:
t.start()
for t in threads:
t.join()</p><p>print(counter)  # 输出：500000，数据正确</p><p><span>立即学习</span>“<a href="https://pan.quark.cn/s/00968c3c2c15" style="text-decoration: underline !important; color: blue; font-weight: bolder;" rel="nofollow" target="_blank">Python免费学习笔记（深入）</a>”；</p>

<pre class="brush:php;toolbar:false;">import threading
import queue
import time
<p>q = queue.Queue(maxsize=5)</p>
                    <div class="aritcle_card">
                        <a class="aritcle_card_img" href="/ai/1101">
                            <img src="https://img.php.cn/upload/ai_manual/001/503/042/68b6c6af75d71275.png" alt="腾讯智影-AI数字人">
                        </a>
                        <div class="aritcle_card_info">
                            <a href="/ai/1101">腾讯智影-AI数字人</a>
                            <p>基于AI数字人能力，实现7*24小时AI数字人直播带货，低成本实现直播业务快速增增，全天智能在线直播</p>
                            <div class="">
                                <img src="/static/images/card_xiazai.png" alt="腾讯智影-AI数字人">
                                <span>73</span>
                            </div>
                        </div>
                        <a href="/ai/1101" class="aritcle_card_btn">
                            <span>查看详情</span>
                            <img src="/static/images/cardxiayige-3.png" alt="腾讯智影-AI数字人">
                        </a>
                    </div>
                <p>def producer():
for i in range(10):
q.put(f"data-{i}")
print(f"Produced: data-{i}")
time.sleep(0.1)</p><p>def consumer():
while True:
try:
data = q.get(timeout=2)
print(f"Consumed: {data}")
q.task_done()
except queue.Empty:
break</p><p>t1 = threading.Thread(target=producer)
t2 = threading.Thread(target=consumer)
t1.start(); t2.start()
t1.join(); t2.join()</p>

<pre class="brush:php;toolbar:false;">import threading
<p>local_data = threading.local()</p><p>def process(name):
local_data.name = name
print(f"Thread {threading.current_thread().name}: {local_data.name}")</p><p>t1 = threading.Thread(target=process, args=("Alice",))
t2 = threading.Thread(target=process, args=("Bob",))
t1.start(); t2.start()
t1.join(); t2.join()</p>

<pre class="brush:php;toolbar:false;">from concurrent.futures import ThreadPoolExecutor
<p>def square(x):
return x * x</p><p>with ThreadPoolExecutor(max_workers=3) as executor:
futures = [executor.submit(square, i) for i in range(5)]
results = [f.result() for f in futures]</p><p>print(results)  # [0, 1, 4, 9, 16]</p>