Python3标准库之threading进程中管理并发操作方法
113 浏览量
2020-12-20
14:04:57
上传
评论
收藏 257KB PDF 举报
Python3标准库之标准库之threading进程中管理并发操作方法进程中管理并发操作方法
1. threading进程中管理并发操作进程中管理并发操作
threading模块提供了管理多个线程执行的API，允许程序在同一个进程空间并发的运行多个操作。
1.1 Thread对象对象
要使用Thread，最简单的方法就是用一个目标函数实例化一个Thread对象，并调用start()让它开始工作。
import threading
def worker():
"""thread worker function"""
print('Worker')
threads = [] for i in range(5):
t = threading.Thread(target=worker)
threads.append(t)
t.start()
输出有5行，每一行都是”Worker”。
如果能够创建一个线程，并向它传递参数告诉它要完成什么工作，那么这会很有用。任何类型的对象都可以作为参数传递到线
程。下面的例子传递了一个数，线程将打印出这个数。
import threading
def worker(num):
"""thread worker function"""
print('Worker: %s' % num)
threads = [] for i in range(5):
t = threading.Thread(target=worker, args=(i,))
threads.append(t)
t.start()
现在这个整数参数会包含在各线程打印的消息中。
1.2 确定当前线程确定当前线程
使用参数来标识或命名线程很麻烦，也没有必要。每个Thread实例都有一个带有默认值的名，该默认值可以在创建线程时改
变。如果服务器进程中有多个服务线程处理不同的操作，那么在这样的服务器进程中，对线程命名就很有用。
import threading
import time
def worker():
print(threading.current_thread().getName(), 'Starting')
time.sleep(0.2)
print(threading.current_thread().getName(), 'Exiting')
def my_service():
print(threading.current_thread().getName(), 'Starting')
time.sleep(0.3)
print(threading.current_thread().getName(), 'Exiting')
t = threading.Thread(name='my_service', target=my_service)
w = threading.Thread(name='worker', target=worker)
w2 = threading.Thread(target=worker) # use default name
w.start()
w2.start()
t.start()
调试输出的每一行中包含有当前线程的名。线程名列中有”Thread-1″的行对应未命名的线程w2。
剩余12页未读，继续阅读
资源评论
