时间提醒

import threading
import logging
import timedef thread_function(name):logging.info("Thread %s starting", name)time.sleep(2000)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 : wait for the thread to finish")logging.info("Main : all done")

daemon

含有daemon标识的线程，当程序结束的时候，线程强制结束

import threading
import logging
import timedef 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,),  daemon=True)x.start()logging.info("Main : wait for the thread to finish")logging.info("Main : all done")

结束子线程后结束主线程

使用join

import threading
import logging
import timedef 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,),  daemon=True)x.start()logging.info("Main : wait for the thread to finish")x.join() # 加上这一句会强制等待所有子线程结束后结束主线程logging.info("Main : all done")

启动多线程的方法

ThreadPoolExecutor头文件

import concurrent.futures

实际调用

with concurrent.futures.ThreadPoolExecutor(max_workers=3) as executor:executor.map(thread_function, range(3))

加锁(包含对with 语句的理解)

生产者消费者线程

快的是生产者(要理发的人)，慢的是消费者(理发师)
生产者排队，将一个随机信息发给消费者

import logging
import threading
import concurrent.futures
import time
import randomSENTINEL = object()class Pipeline(object):def __init__(self):self.message = 0self.producer_lock = threading.Lock()self.consumer_lock = threading.Lock()self.consumer_lock.acquire()def get_message(self, name):logging.debug("%s: about to acquire getlock", name)self.consumer_lock.acquire()logging.debug("%s: have getlock", name)message = self.messagelogging.debug("%s: about to release setlock", name)self.producer_lock.release()logging.debug("%s: setlock released", name)return messagedef set_message(self, message, name):logging.debug("%s: about to acquire setlock", name)self.producer_lock.acquire()logging.debug("%s: have setlock", name)self.message = messagelogging.debug("%s: about to release getlock", name)self.consumer_lock.release()logging.debug("%s: have released getlock", name)def producer(pipeline):'''pretend we are getting a message from the network'''for index in range(10):message = random.randint(1, 101)logging.info("Producer got message: %s", message)pipeline.set_message(message, "Producer")# send a sentinel message to tell consumer we're donepipeline.set_message(SENTINEL, "Producer")def consumer(pipeline):message = 0while message is not SENTINEL:message = pipeline.get_message("Consumer")if message is not SENTINEL:logging.info("Consumer storing message %s", message)if __name__ == '__main__':format = "%(asctime)s: %(message)s"logging.getLogger().setLevel(logging.DEBUG)logging.basicConfig(format=format, level=logging.INFO, datefmt="%H:%M:%S")pipeline = Pipeline()with concurrent.futures.ThreadPoolExecutor(max_workers=2) as executor:executor.submit(producer, pipeline)executor.submit(consumer, pipeline)

多进程读写锁

写的时候不能有人读或者写，读的时候没人写就行

import logging
import threading
import concurrent.futures
import time
import randomSENTINEL = object()class Pipeline(object):def __init__(self):self.message = 0self.producer_lock = threading.Lock()self.consumer_lock = threading.Lock()def get_message(self, name):while True:if not self.producer_lock.locked():logging.debug("%s: no write, begin to read", name)self.consumer_lock.acquire()logging.debug("%s: have get readlock", name)message = self.messagelogging.debug("%s: have get the message, about to release readlock", name)self.consumer_lock.release()breakreturn messagedef set_message(self, message, name):while True:if not self.consumer_lock.locked() and not self.producer_lock.locked():logging.debug("%s: no write and read, begin to write", name)self.producer_lock.acquire()logging.debug("%s: get setlock", name)self.message = messagelogging.debug("%s: setover about to release setlock", name)self.producer_lock.release()breakreturndef producer(pipeline):'''pretend we are getting a message from the network'''for index in range(10):message = random.randint(1, 101)logging.info("Producer got message: %s", message)pipeline.set_message(message, "Producer")# send a sentinel message to tell consumer we're donepipeline.set_message(SENTINEL, "Producer")def consumer(pipeline):message = 0while message is not SENTINEL:message = pipeline.get_message("Consumer")if message is not SENTINEL:logging.info("Consumer storing message %s", message)if __name__ == '__main__':format = "%(asctime)s: %(message)s"logging.getLogger().setLevel(logging.DEBUG)logging.basicConfig(format=format, level=logging.INFO, datefmt="%H:%M:%S")pipeline = Pipeline()with concurrent.futures.ThreadPoolExecutor(max_workers=3) as executor:executor.submit(producer, pipeline)executor.submit(producer, pipeline)executor.submit(consumer, pipeline)

python多线程信息提示相关推荐

基于python多线程和Scrapy爬取链家网房价成交信息
文章目录知识背景 Scrapy- spider 爬虫框架 SQLite数据库 python多线程爬取流程详解爬取房价信息封装数据库类,方便多线程操作数据库插入操作构建爬虫爬取数据基于百度 ...
python多线程爬虫实例-Python实现多线程爬虫
编辑推荐: 本文主要介绍对Python多线程爬虫实战的整体的思路,希望对大家有帮助. 本文来知乎,由火龙果软件Alice编辑,推荐. 最近在写爬虫程序爬取亚马逊上的评论信息,因此也自学了很多爬虫相关的 ...
使用Python多线程犯的错误总结
在使用Python多线程的时候,在使用多线程编程的时候,由于对于变量作用域和多线程不是很熟悉,导致在使用多线程的时候,犯了低级的错误. 第一个错误: 在多线程中使用全局变量,导致多个线程修改全局变量. ...
python多线程实现访问页面_Python实现多线程爬虫
最近在写爬虫程序爬取亚马逊上的评论信息,因此也自学了很多爬虫相关的知识,其实网络上已经有很多基于Python的入门爬虫程序了,所以学习起来比较方便,唯独那个多线程爬虫一直都学的不是很明白,所以就写下这 ...
python 多线程和协程结合_一文讲透 “进程、线程、协程”
本文从操作系统原理出发结合代码实践讲解了以下内容: 什么是进程,线程和协程? 它们之间的关系是什么? 为什么说Python中的多线程是伪多线程? 不同的应用场景该如何选择技术方案? ... 什么是进程 ...
python 多线程及线程间通信
python 多线程 import threading import time def run(n):print("task", n)time.sleep(1)print('2s' ...
python多线程和多进程的使用_python多线程与多进程
python多线程与多进程 python多线程 python中提供两个标准库thread和threading用于对线程的支持,python3中已放弃对前者的支持,后者是一种更高层次封装的线程库,接下来 ...
人生苦短之Python多线程
#encoding=utf-8 import threading import time''' python多线程并不是真正意义上的多线程,通常我们所说的多线程是多个线程同时执行某功能,而在pytho ...
python多线程输出_Python多线程
多线程基础概念并行与并发并行:同时处理多个任务,必须在多核环境下一段时间内同时处理多个任务,单核也可以并发并发手段线程:内核空间的调度进程:内核空间的调度协程:用户空间的调度线程可以允 ...

python多线程信息提示

时间提醒

daemon

结束子线程后结束主线程

启动多线程的方法

加锁(包含对with 语句的理解)

生产者消费者线程

多进程读写锁

python多线程信息提示相关推荐

最新文章

热门文章