python 线程

import threading

# 定义一个线程类
class MyThread(threading.Thread):
    def __init__(self, thread_id, name, counter):
        threading.Thread.__init__(self)
        self.thread_id = thread_id
        self.name = name
        self.counter = counter

    def run(self):
        print(f"启动线程: {self.name}")
        # 获取锁，用于线程同步
        thread_lock.acquire()
        print_time(self.name, self.counter, 3)
        # 释放锁
        thread_lock.release()

def print_time(thread_name, delay, counter):
    while counter:
        print(f"{thread_name}: {time.ctime(time.time())}")
        time.sleep(delay)
        counter -= 1

thread_lock = threading.Lock()
threads = []

# 创建新线程
thread1 = MyThread(1, "Thread-1", 1)
thread2 = MyThread(2, "Thread-2", 2)

# 开启新线程
thread1.start()
thread2.start()

# 添加线程到线程列表
threads.append(thread1)
threads.append(thread2)

# 等待所有线程完成
for t in threads:
    t.join()

print("退出主线程")

解释说明：

1. 导入模块：threading 模块用于创建和管理线程。
2. 定义线程类：继承 threading.Thread 类，重写 run 方法来定义线程执行的任务。
3. 线程同步：使用 threading.Lock() 来确保多个线程不会同时访问共享资源。
4. 创建和启动线程：通过实例化 MyThread 类并调用 start() 方法来启动线程。
5. 等待线程结束：使用 join() 方法确保主线程等待所有子线程完成后再继续执行。