Python多线程编程（一）
什么是多线程？
说到多线程，不得不说的就是进程。线程是属于进程的。一个进程中，可以有一个或多个线程。 多线程的出现就是为了同时执行多个不同程序，提高资源使用效率来提高系统的效率。
Python的标准库提供了两个模块：thread和threading，thread是低级模块，threading是高级模块，对thread进行了封装。绝大多数情况下，我们只需要使用threading这个高级模块。
创建线程
Python标准库提供了threading库，并且封装好了接口，我们只需要调用即可。 创建一个线程就是把一个函数传入并创建Thread实例，然后调用start()开始执行：
import logging
import threading
import time
def thread_function(name):
logging.info("Thread %s: starting", name)
time.sleep(2)
logging.info("Thread %s: finishing", name)
if __name__ == "__main__":
format = "%(asctime)s: %(message)s"
logging.basicConfig(format=format, level=logging.INFO,
datefmt="%H:%M:%S")
logging.info("Main : before creating thread")
x = threading.Thread(target=thread_function, args=(1,))
logging.info("Main : before running thread")
x.start()
logging.info("Main : wait for the thread to finish")
# x.join()
logging.info("Main : all done")如果你查看日志语句，你可以看到创建和启动线程，下面两句就是关键部分:
x = threading.Thread(target=thread_function, args=(1,))
x.start()创建线程时，将传递一个函数和一个包含该函数参数的列表。在实例中，我们告诉线程运行thread_function()并传递参数1。目前thread_function()没有多大作用。它只是记录一些消息。
运行程序，将输出如下结果：
Main : before creating thread
Main : before running thread
Thread 1: starting
Main : wait for the thread to finish
Main : all done启动多线程
上面的启动方式，只能起一个主线程和一个线程。通常我们是有线程，肯定是需要启动多线程，来做一些有趣的事情。该怎么做呢？
import logging
import time
import concurrent.futures
def thread_function(name):
logging.info("Thread %s: starting", name)
time.sleep(2)
logging.info("Thread %s: finishing", name)
if __name__ == "__main__":
format = "%(asctime)s: %(message)s"
logging.basicConfig(format=format, level=logging.INFO,
datefmt="%H:%M:%S")
with concurrent.futures.ThreadPoolExecutor(max_workers=3) as executor:
executor.map(thread_function, range(3))这段代码创建一个ThreadPoolExecutor作为上下文管理器，告诉它在线程池中需要多少个线程。然后，它使用.map()遍历range(3)为例的可迭代对象，将每个对象传递给池中的线程。
运行程序，将输出如下结果：
Thread 0: starting
Thread 1: starting
Thread 2: starting
Thread 1: finishing
Thread 0: finishing
Thread 2: finishing本文参与 腾讯云自媒体分享计划，分享自微信公众号。
原始发表：2019-03-29，如有侵权请联系 cloudcommunity@tencent.com 删除
评论
登录后参与评论
推荐阅读
目录