文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

Python多线程与高并发

2023-01-31 05:29

关注
主要讲解了关于Python多线程的一些例子和高并发的一些应用场景
# -*- coding: utf-8 -*-
# @Author: Clarence
# @Date:   2018-02-28 20:39:31
# @Last Modified by:   Clarence
# @Last Modified time: 2018-02-28 23:29:54
"""
涉及知识点
互斥锁 线程
在大部分的编程语言当中,线程都是编程当中十分重要的概念,Python也不例外。
"""

# 写一个简单的单线程程序
import time
import threading

# def saysorry():
# 	print('我错了')
# 	time.sleep(1)

# if __name__ == '__main__':
# 	for i in range(5):
# 		t = threading.Thread(target=saysorry)
# 		t.start()

"""
1.当用继承的方式去创建线程时,一定要重写父类的Run()方法
2.当线程的run()方法结束的时候,线程也结束
3.我们认为是无法完全控制线程的,但是我们可以通过一些方式来影响线程的调用
4.线程的几种状态 新建----就绪----运行-----死亡 等待(阻塞)主要出现就绪与运行之间
"""
class MyThread(threading.Thread):
	def run(self):
		for i in range(5):
			msg = '线程' + self.name + str(i)
			print(msg)

# 单线程 注意 若调用start,则先执行主线程的,后执行子线程的 若调用run()方法,则相当于函数调用,按照程序的顺序执行
if __name__ == '__main__':
	t = MyThread()
	t.start()



"""
import time 
import threading 
num = 0
class MyThread(threading.Thread):
	# 告诉python解释器,我要对全局变量进行修改了
	global num
	num = num + 1
	time.sleep(1)
	msg = self.name + 'set num to' + str(num)
	print(msg)

def test():
	for i in range(5):
		t = MyThread()
		t.start()

if __name__ == '__main__':
	test()
"""

# -*- coding: utf-8 -*-
# @Author: Clarence
# @Date:   2018-02-28 21:40:58
# @Last Modified by:   Clarence
# @Last Modified time: 2018-02-28 23:40:58

"""
当一个线程调用锁的acquire方法时,获得锁,锁就会进入上锁状态
每次只有一个线程可以获得锁,如果此时另个一个线程试图获得这个锁时,该线程就会进入
阻塞状态,直到拥有锁的线程调用了release()方法释放锁之后,其他线程才能够获得这把锁
总结: 锁的好处,确保了某段关键代码只能有一个线程从头到尾执行,保证了数据的唯一性

锁的坏处:
1.阻止了多线程并发执行 效率大大降低
2.由于可以存在多个锁,不同的线程持有不同的锁,并试图获取对方的锁, 可能就会
造成死锁

高并发服务器应用场所 web开发 区块链 同时 线程 进程 协程
"""

import threading 
import time
num = 0
#创建一把锁
mutex = threading.Lock()
class MyThread(threading.Thread):
	def run(self):
		global num
		#上锁
		mutexFlage = mutex.acquire()
		print('线程(%s)的锁状态为%d' %(self.name, mutexFlage))
		#判断是否上锁成功
		if mutexFlage:
			num = num + 1
			time.sleep(1)
			msg = self.name + 'set num to' + str(num)
			print(msg)
			print(threading.currentThread(), threading.activeCount())
			mutex.release()

def test():
	for i in range(5):
		t = MyThread()
		print(threading.currentThread(), threading.activeCount())
		t.start()

if __name__ == '__main__':
	test()
这几个例子比较简单,关于线程的一些基本概念我会给大家整理好,也同时自己复习一遍。
阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     807人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     351人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     314人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     433人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     221人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯