1、多线程类的继承

import threading

import time

class MyThreading(threading.Thread):

    def __init__(self,n):

        super(MyThreading,self).__init__()

        self.n = n

    def run(self):

        print("threading %s"%(self.n))

        time.sleep(2)

threading1 = MyThreading("%s" %(1))

threading2 = MyThreading("%s" %(2))

threading1.start()

threading1.join() ## 1执行完才会执行2

threading2.start()

E:\Users\xiajinqi\PycharmProjects\Atm\venv\Scripts\python.exe E:/Users/xiajinqi/PycharmProjects/Atm/test4.py

threading 1

threading 2

。。。。。。。

2、线程测试案例

import threading

import time

class MyThreading(threading.Thread):

    def __init__(self,n):

        super(MyThreading,self).__init__()

        self.n = n

    def run(self):

        time.sleep(2)

        print("threading %s"%(self.n))

threading1 = MyThreading("%s" %(1))

threading2 = MyThreading("%s" %(2))

threading1.start()

threading1.join() ## 1执行完才会执行2

threading2.start()

print("main")

E:\Users\xiajinqi\PycharmProjects\Atm\venv\Scripts\python.exe E:/Users/xiajinqi/PycharmProjects/Atm/test4.py

threading 1

main

threading 2

3、多线程时间测试案例

import threading

import time

list = [ ]

def run(i):

    print("test %s"%(i))

    time.sleep(2)

starttime = time.time()

for i in range(1,50):

    t1 = threading.Thread(target=run,args=(i,))

    t1.start()

    list.append(t1)

for i in  list :

    i.join()

print("end")

endtime = time.time()

print("cost:", endtime-starttime)

E:\Users\xiajinqi\PycharmProjects\Atm\venv\Scripts\python.exe E:/Users/xiajinqi/PycharmProjects/Atm/test3.py

test 1

test 2

test 3

test 4

test 5

test 6

test 7

test 8

test 9

test 10

test 11

test 12

test 13

test 14

test 15

test 16

test 17

test 18

test 19

test 20

test 21

test 22

test 23

test 24

test 25

test 26

test 27

test 28

test 29

test 30

test 31

test 32

test 33

test 34

test 35

test 36

test 37

test 38

test 39

test 40

test 41

test 42

test 43

test 44

test 45

test 46

test 47

test 48

test 49

end

cost: 2.007871150970459

Process finished with exit code 0

　4、守护线程概念，默认情况下为非守护线程，即主线程推出前，需要等待所有的非守护线程结束放可以推出。而守护线程就表示这个线程“不重要”，即主线程结束时候，无需等待守护线程是否执行完成。

import threading

import time

list = [ ]

def run(i):

    print("test %s"%(i))

    time.sleep(5)

    print("setDaemon end ")

starttime = time.time()

for i in range(1,50):

    t1 = threading.Thread(target=run,args=(i,))

#    t1.setDaemon(True)

    t1.start()

    list.append(t1)

print("main  end")

E:\Users\xiajinqi\PycharmProjects\Atm\venv\Scripts\python.exe E:/Users/xiajinqi/PycharmProjects/Atm/test3.py

test 1

test 2

test 3

test 4

test 5

test 6

test 7

test 8

test 9

test 10

test 11

test 12

test 13

test 14

test 15

test 16

test 17

test 18

test 19

test 20

test 21

test 22

test 23

test 24

test 25

test 26

test 27

test 28

test 29

test 30

test 31

test 32

test 33

test 34

test 35

test 36

test 37

test 38

test 39

test 40

test 41

test 42

test 43

test 44

test 45

test 46

test 47

test 48

test 49

main  end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end

setDaemon end 

Process finished with exit code 0

import threading

import time

list = [ ]

def run(i):

    print("test %s"%(i))

    time.sleep(5)

    print("setDaemon end ")

starttime = time.time()

for i in range(1,50):

    t1 = threading.Thread(target=run,args=(i,))

    t1.setDaemon(True)

    t1.start()

    list.append(t1)

print("main  end")

E:\Users\xiajinqi\PycharmProjects\Atm\venv\Scripts\python.exe E:/Users/xiajinqi/PycharmProjects/Atm/test3.py

test 1

test 2

test 3

test 4

test 5

test 6

test 7

test 8

test 9

test 10

test 11

test 12

test 13

test 14

test 15

test 16

test 17

test 18

test 19

test 20

test 21

test 22

test 23

test 24

test 25

test 26

test 27

test 28

test 29

test 30

test 31

test 32

test 33

test 34

test 35

test 36

test 37

test 38

test 39

test 40

test 41

test 42

test 43

test 44

test 45

test 46

test 47

test 48

test 49

main  end

Process finished with exit code 0

5、GIL 和线程锁。GIL就是一把全局排他锁。他的作用就是保证同一时刻只有一个线程可以执行代码,对多线程有较大影响。

import threading

import time

lock  = threading.Lock()

list = [ ]

res = 0

def run(i):

    # 在Python3.5中已经优化，结果都是50.在python2.7如果不加锁可能有一场

    lock.acquire()

    global res

    res =  res + 1

    lock.release()

starttime = time.time()

for i in range(0,50):

    t1 = threading.Thread(target=run,args=(i,))

    t1.setDaemon(True)

    t1.start()

    list.append(t1)

for i in list:

    i.join()

print(res)

6、当有多重锁时候，可以使用Rlock,使用递归锁可以避免出现死锁的情况

7、信号量简单实用。信号量就相当于多把锁

# Author : xiajinqi

import threading

import time

semaphore = threading.BoundedSemaphore()

def run(i):

    semaphore.acquire()

    print("阮娇。。。。")

    time.sleep()

    semaphore.release()

for i  in range(,):

    tt = threading.Thread(target=run,args=(i,))

    tt.start()

8、event 在线程间简单应用，车子等红灯

# Author : xiajinqi

import threading

import time

event = threading.Event()

#  - 绿灯 -20红灯，大于二十从0开始

def lighter():

    count =

    while  True :

        if count >=  and count < :

            event.clear()

            print("当前红灯")

            count = count +

        elif count >= :

            count =

        else :

            event.set()

            print("当前绿灯")

            count +=

        time.sleep()

def run():

    while True :

        time.sleep()

        if event.is_set() : #event.waite( 如果没有值，就会一直卡主等待

            print("开始过十字路口")

        else :

            print("开始等车")

            event.wait()

t1 = threading.Thread(target=lighter)

t2 = threading.Thread(target=run)

t1.start()

t2.start()

9、队列queue和列表、元组的区别。二者都有顺序。但是从列表取一个数据，数据还存在。而队列取出一个数据以后，改数据在队列就会被清空。符合实际应用场景。队列有三种:一、先进先去 二、先进后去 三、可以设置优先级别的队

import queue

# 先进先去

qu= queue.Queue()

for i in range(1,5):

    qu.put(i)

while qu.qsize() >0:

    print(qu.get())

# 先进后去

import queue

# 先进先去

qu= queue.LifoQueue()

for i in range(1,5):

    qu.put(i)

while qu.qsize() >0:

    print(qu.get())

E:\Users\xiajinqi\PycharmProjects\Atm\venv\Scripts\python.exe E:/Users/xiajinqi/PycharmProjects/Atm/333.py

4

3

2

1

import queue

# 具有优先级别的队列 .类型需要一样

qq= queue.PriorityQueue()

list =[(1,"xiajinqi"),(1,"test"),(2,"test2"),(3,"test3"),(5,"test5"),(3,"test3")]

for lt in list:

    qq.put(lt)

while qq.qsize() >0:

    print(qq.get())

import queue

# 具有优先级别的队列 .类型需要一样

qq= queue.PriorityQueue()

list =[(1,"xiajinqi"),(1,"test"),(2,"test2"),(3,"test3"),(5,"test5"),(3,"test3")]

for lt in list:

    qq.put(lt)

while qq.qsize() >0:

    print(qq.get())

　　

10、消费者生产者模型，解耦，相互不影响

import queue

import time

import threading

qu = queue.Queue(maxsize=)

# 每次生产十个

def Producder():

    while True:

        for i  in range(,):

            print("生产了两个骨头")

            qu.put("骨头 %s"%(i))

        time.sleep()

# 生产者消费者模型，多个人生产多个人消费。

def Consumer(name) :

    while True:

        print("%s 吃了一个骨头 %s"%(name,qu.get()))

        time.sleep(0.5)

#两个消费

c1 = threading.Thread(target=Consumer,args=("test1",))

c2 = threading.Thread(target=Consumer,args=("test2",))

pd1 = threading.Thread(target=Producder)

pd1.start()

c1.start()

c2.start()

最新文章

  1. JS实现常用排序算法—经典的轮子值得再造
  2. requireJs--简单的使用方法
  3. APP设计尺寸规范大全，APP界面设计新手教程【官方版】(转)
  4. java mybatis 中sql 模糊查询
  5. 通过jekyll建立静态网页
  6. Java中快如闪电的线程间通讯
  7. js:深闭包(范围：上)
  8. 201521123081《Java程序设计》 第8周学习总结
  9. Angular2响应式表单
  10. 20155214&amp;20155216 实验二：固件程序设计
  11. Git使用七：修改最后一次提交、删除文件和重命名文件
  12. 洛谷P3740 【[HAOI2014]贴海报】
  13. Salesforce 小知识 - 必需字段
  14. 算法笔记_223:打印回型嵌套(Java)
  15. servlet 中通过response下载文件
  16. openstack neutron中涉及的网络设备
  17. Vue 列表渲染及条件渲染实战
  18. Eclipse改变相同代码高亮颜色
  19. PHP扩展类ZipArchive实现压缩解压Zip文件和文件打包下载 &amp;&amp; Linux下的ZipArchive配置开启压缩 &amp;&amp;搞个鸡巴毛，写少了个‘/’号，浪费了一天
  20. Apache入门篇（四）之LAMP架构部署

热门文章

  1. Redis 在Golang中使用遇到的坑
  2. WCF已超过传入消息(65536)的最大消息大小配额。若要增加配额，请使用相应绑定元素上的 MaxReceivedMessageSize 属性
  3. August 21st 2017 Week 34th Monday
  4. There was a problem confirming the ssl certificate: [SSL: TLSV1_ALERT_PROTOCOL_VERSION] tlsv1 alert protocol version (_ssl.c:661) - skipping
  5. 使用Java语言开发机器学习框架和参数服务器
  6. AngularJs学习笔记--Using $location
  7. JavaScript正则表达式_常用的正则
  8. Django重定向的写法、与直接渲染的区别
  9. MyBatis使用自定义TypeHandler转换类型的实现方法
  10. Level/levelup-2-API