河南多线程服务器云主机

import threading

# 示例代码：使用互斥锁保护共享资源
lock = threading.Lock()
shared_resource = 0

def thread_task():
    global shared_resource
    for _ in range(100000):
        lock.acquire()
        shared_resource += 1
        lock.release()

threads = []
for i in range(10):
    t = threading.Thread(target=thread_task)
    threads.append(t)
    t.start()

for t in threads:
    t.join()

print(shared_resource)  # 输出应为1000000

import threading

# 示例代码：避免死锁
lock1 = threading.Lock()
lock2 = threading.Lock()

def thread_task1():
    lock1.acquire()
    print("Thread 1 acquired lock1")
    lock2.acquire()
    print("Thread 1 acquired lock2")
    lock2.release()
    lock1.release()

def thread_task2():
    lock2.acquire()
    print("Thread 2 acquired lock2")
    lock1.acquire()
    print("Thread 2 acquired lock1")
    lock1.release()
    lock2.release()

t1 = threading.Thread(target=thread_task1)
t2 = threading.Thread(target=thread_task2)

t1.start()
t2.start()

t1.join()
t2.join()

import concurrent.futures

# 示例代码：使用线程池
def task(n):
    return n * n

with concurrent.futures.ThreadPoolExecutor(max_workers=5) as executor:
    results = list(executor.map(task, range(10)))

print(results)  # 输出应为[0, 1, 4, 9, 16, 25, 36, 49, 64, 81]