• <input id="4imo2"><tt id="4imo2"></tt></input>
  • <object id="4imo2"><acronym id="4imo2"></acronym></object>
    <object id="4imo2"></object>
  • <menu id="4imo2"><u id="4imo2"></u></menu>
    <object id="4imo2"></object>
  • <menu id="4imo2"></menu><input id="4imo2"><u id="4imo2"></u></input><input id="4imo2"><u id="4imo2"></u></input>
    <input id="4imo2"></input>
  • day30总结

    回顾

    1.进程互斥锁
    让并发变成串行,牺牲了效率,保证数据安全.
    mutex = Lock()
    # 加锁
    ? mutex.acquire()
    # 释放锁
    ? mutex.release()

    2.队列:
    相当于在内存中开启了一个空间,可以存放一堆数据,这堆数据都得遵循"先进先出".
    管道(阻塞) + 锁
    q = Queue()
    # 添加数据
    ? q.put(1)
    # 若队列满了,会原地等待
    ? q.put(2)
    # 若队列满了,不会等待直接报错
    ? q.put_nowait(2)

    获取数据,遵循先进先出
    若队列中没数据,会原地等待
    q.get() # 1
    若队列中没数据,会直接报错
    q.get_nowait() # 1

    q.empty() # 判断队列是否为空
    q.full() # 判断队列是否满了

    3.IPC进程间通信
    通过队列让进程间实现通信.

    4.生产者与消费者
    生产者: 生产数据的
    消费者; 使用数据的

    目的: 解决供需不平衡问题.
    通过队列来实现,生产者消费者供需不平衡问题.

    5.线程
    1.什么是线程?
    进程: 资源单位
    线程: 执行单位

    注意: 只要开启一个进程就会有一个线程(主线程).
    主线程会在进程结束时,一并销毁.

    2.为什么要使用线程?
    节省内存资源

    开启进程:
    1) 开辟一个新的内存空间
    2) 会自带一个主线程

    开启线程:
    1) 一个进程内可以开启多个线程
    2) 开启线程的资源远小于进程

    创建线程的两种方式
    一:
    from threading import Thread
    def task():
    pass

    t = Thread(target=task) # 异步提交任务,开启线程
    t.start()
    t.join() # 主线程等待子线程结束之后再结束.

    二:
    class MyThread(Thread):
    def run(self):
    执行任务
    ? pass

    t = MyThread()
    t.start()
    t.join()

    6.线程对象的属性
    current_thread().name # 获取当前线程对象的名字
    # 返回一个列表,列表中包含当前执行的所有线程对象
    print(enumerate())
    # 获取当前执行线程的个数
    print(activeCount())
    is_alive() # 判断线程是否存活

    7.线程互斥锁
    from threading import Lock()
    mutex = Lock()
    mutex.acquire()
    t1
    mutex.release()

    TCP服务端实现并发

    '''
    服务端的工作:
        1.接收客户端的请求
        2.24小时不间断提供服务
        3.实现并发
    
    '''
    
    import socket
    import time
    from threading import Thread
    
    server = socket.socket()
    
    server.bind(
        ('127.0.0.1', 9527)
    )
    
    server.listen(5)
    print('启动服务端...')
    
    
    # 线程任务,执行接收客户端消息与发送消息给客户端
    def working(conn):
        while True:
            try:
                data = conn.recv(1024)
                if len(data) == 0:
                    break
                print(data)
                time.sleep(1)
                conn.send(data.upper())
            except Exception as e:
                print(e)
                break
    
        conn.close()
    
    
    while True:
        conn, addr = server.accept()
        print(addr)
        t = Thread(target=working, args=(conn, ))
        t.start()xxxxxxxxxx?'''服务端的工作: ?  1.接收客户端的请求 ?  2.24小时不间断提供服务 ?  3.实现并发'''import socketimport timefrom threading import Threadserver = socket.socket()server.bind( ?  ('127.0.0.1', 9527))server.listen(5)print('启动服务端...')# 线程任务,执行接收客户端消息与发送消息给客户端def working(conn): ?  while True: ? ? ?  try: ? ? ? ? ?  data = conn.recv(1024) ? ? ? ? ?  if len(data) == 0: ? ? ? ? ? ? ?  break ? ? ? ? ?  print(data) ? ? ? ? ?  time.sleep(1) ? ? ? ? ?  conn.send(data.upper()) ? ? ?  except Exception as e: ? ? ? ? ?  print(e) ? ? ? ? ?  break ?  conn.close()while True: ?  conn, addr = server.accept() ?  print(addr) ?  t = Thread(target=working, args=(conn, )) ?  t.start()'''服务端的工作: ?  1.接收客户端的请求 ?  2.24小时不间断提供服务 ?  3.实现并发'''import socketimport timefrom threading import Threadserver = socket.socket()server.bind( ?  ('127.0.0.1', 9527))server.listen(5)print('启动服务端...')# 线程任务,执行接收客户端消息与发送消息给客户端def working(conn): ?  while True: ? ? ?  try: ? ? ? ? ?  data = conn.recv(1024) ? ? ? ? ?  if len(data) == 0: ? ? ? ? ? ? ?  break ? ? ? ? ?  print(data) ? ? ? ? ?  time.sleep(1) ? ? ? ? ?  conn.send(data.upper()) ? ? ?  except Exception as e: ? ? ? ? ?  print(e) ? ? ? ? ?  break ?  conn.close()while True: ?  conn, addr = server.accept() ?  print(addr) ?  t = Thread(target=working, args=(conn, )) ?  t.start()
    import socket
    import time
    
    client = socket.socket()
    
    client.connect(
        ('127.0.0.1', 9527)
    )
    
    print('启动客户端...')
    while True:
        client.send(b'hello')
        data = client.recv(1024)
        print(data)
        time.sleep(1)

    GIL全局解释器锁

    '''
    In CPython, the global interpreter lock, or GIL, is a mutex that prevents multiple
    native threads from executing Python bytecodes at once. This lock is necessary mainly
    because CPython’s memory management is not thread-safe. (However, since the GIL
    exists, other features have grown to depend on the guarantees that it enforces.)
    
    在CPython中,全局解释器锁(GIL)是一个防止多个锁的互斥锁
    本机线程从执行Python字节码一次。这把锁主要是必须的
    因为CPython的内存管理不是线程安全的。(然而,自从GIL
    存在时,其他功能已逐渐依赖于它所实施的保证。)
    
    '''
    
    '''
    python解释器:
        1.Cpython
            C
            
        2.Jpython
            java
            
        3.Ppython
            Python
    
    
    GIL全局解释器锁:
        基于Cpython来研究全局解释器锁.
        
        1.GIL本质上是一个互斥锁.
        2.GIL的为了阻止同一个进程内多个线程同时执行(并行)
            - 单个进程下的多个线程无法实现并行,但能实现并发
        
        3.这把锁主要是因为CPython的内存管理不是 "线程安全" 的.
            - 内存管理
                - 垃圾回收机制
                
        GIL的存在就是为了保证线程安全的.
        
        注意: 多个线程过来执行,一旦遇到IO操作,就会立马释放GIL解释器锁,交给下一个先进来的线程.
        
    '''
    
    import time
    from threading import Thread, current_thread
    
    number = 100
    
    
    def task():
        global number
        number2 = number
        # time.sleep(1)
        number = number2 - 1
        print(number, current_thread().name)
    
    
    for line in range(100):
        t = Thread(target=task)
        t.start()

    验证多线程的作用

    '''
    多线程的作用:
        站在两个角度去看问题:
    
        - 四个任务, 计算密集型, 每个任务需要10s:
            单核:
                - 开启进程
                    消耗资源过大
                    - 4个进程: 40s
    
                - 开启线程
                    消耗资源远小于进程
                    - 4个线程: 40s
    
            多核:
                - 开启进程
                    并行执行,效率比较高
                    - 4个进程: 10s
    
                - 开启线程
                    并发执行,执行效率低.
                    - 4个线程: 40s
    
    
    
        - 四个任务, IO密集型, 每个任务需要10s:
            单核:
                - 开启进程
                    消耗资源过大
                    - 4个进程: 40s
    
                - 开启线程
                    消耗资源远小于进程
                    - 4个线程: 40s
    
            多核:
                - 开启进程
                    并行执行,效率小于多线程,因为遇到IO会立马切换CPU的执行权限
                    - 4个进程: 40s  +  开启进程消耗的额外时间
    
                - 开启线程
                    并发执行,执行效率高于多进程
    
                    - 4个线程: 40s
    '''
    from threading import Thread
    from multiprocessing import Process
    import os
    import time
    
    
    # 计算密集型
    def work1():
        number = 0
        for line in range(100000000):
            number += 1
    
    
    # IO密集型
    def work2():
        time.sleep(1)
    
    
    if __name__ == '__main__':
    
        # 测试计算密集型
        # print(os.cpu_count())  # 6
        # # 开始时间
        # start_time = time.time()
        # list1 = []
        # for line in range(6):
        #     p = Process(target=work1)  # 程序执行时间5.300818920135498
        #     # p = Thread(target=work1)  # 程序执行时间24.000795602798462
        #
        #     list1.append(p)
        #     p.start()
    
        # IO密集型
        print(os.cpu_count())  # 6
        # 开始时间
        start_time = time.time()
        list1 = []
        for line in range(40):
            # p = Process(target=work2)  # 程序执行时间4.445072174072266
            p = Thread(target=work2)  # 程序执行时间1.009237289428711
    
            list1.append(p)
            p.start()
    
        for p in list1:
            p.join()
        end_time = time.time()
    
        print(f'程序执行时间{end_time - start_time}')
    
    
    
    
    '''
    在计算密集型的情况下:
        使用多进程
        
    在IO密集型的情况下:
        使用多线程
        
    高效执行多个进程,内多个IO密集型的程序:
        使用 多进程 + 多线程
    '''

    死锁现象

    '''
    死锁现象(了解):
    
    '''
    from threading import Lock, Thread, current_thread
    import time
    
    mutex_a = Lock()
    mutex_b = Lock()
    #
    # print(id(mutex_a))
    # print(id(mutex_b))
    
    
    class MyThread(Thread):
    
        # 线程执行任务
        def run(self):
            self.func1()
            self.func2()
    
        def func1(self):
            mutex_a.acquire()
            # print(f'用户{current_thread().name}抢到锁a')
            print(f'用户{self.name}抢到锁a')
            mutex_b.acquire()
            print(f'用户{self.name}抢到锁b')
            mutex_b.release()
            print(f'用户{self.name}释放锁b')
            mutex_a.release()
            print(f'用户{self.name}释放锁a')
    
        def func2(self):
            mutex_b.acquire()
            print(f'用户{self.name}抢到锁b')
            # IO操作
            time.sleep(1)
    
            mutex_a.acquire()
            print(f'用户{self.name}抢到锁a')
            mutex_a.release()
            print(f'用户{self.name}释放锁a')
            mutex_b.release()
            print(f'用户{self.name}释放锁b')
    
    
    for line in range(10):
        t = MyThread()
        t.start()
    
    
    '''
    注意:
        锁不能乱用.
    '''

    递归锁

    '''
    递归锁(了解):
        用于解决死锁问题.
    
    RLock: 比喻成万能钥匙,可以提供给多个人去使用.
        但是第一个使用的时候,会对该锁做一个引用计数.
        只有引用计数为0, 才能真正释放让另一个人去使用
    '''
    
    from threading import RLock, Thread, Lock
    import time
    
    mutex_a = mutex_b = Lock()
    
    
    class MyThread(Thread):
    
        # 线程执行任务
        def run(self):
            self.func1()
            self.func2()
    
        def func1(self):
            mutex_a.acquire()
            # print(f'用户{current_thread().name}抢到锁a')
            print(f'用户{self.name}抢到锁a')
            mutex_b.acquire()
            print(f'用户{self.name}抢到锁b')
            mutex_b.release()
            print(f'用户{self.name}释放锁b')
            mutex_a.release()
            print(f'用户{self.name}释放锁a')
    
        def func2(self):
            mutex_b.acquire()
            print(f'用户{self.name}抢到锁b')
            # IO操作
            time.sleep(1)
            mutex_a.acquire()
            print(f'用户{self.name}抢到锁a')
            mutex_a.release()
            print(f'用户{self.name}释放锁a')
            mutex_b.release()
            print(f'用户{self.name}释放锁b')
    
    
    for line in range(10):
        t = MyThread()
        t.start()

    信号量

    '''
    信号量(了解):
    
        互斥锁: 比喻成一个家用马桶.
            同一时间只能让一个人去使用
    
        信号量: 比喻成公厕多个马桶.
            同一时间可以让多个人去使用
    '''
    from threading import Semaphore, Lock
    from threading import current_thread
    from threading import Thread
    import time
    
    sm = Semaphore(5)  # 5个马桶
    mutex = Lock()  # 5个马桶
    
    
    def task():
        # mutex.acquire()
        sm.acquire()
        print(f'{current_thread().name}执行任务')
        time.sleep(1)
        sm.release()
        # mutex.release()
    
    
    for line in range(20):
        t = Thread(target=task)
        t.start()

    线程队列

    '''
    线程Q(了解级别1): 线程队列  面试会问: FIFO
    
        - FIFO队列: 先进先出
        - LIFO队列: 后进先出
        - 优先级队列: 根据参数内,数字的大小进行分级,数字值越小,优先级越高
    '''
    import queue
    
    # 普通的线程队列: 先进先出
    # q = queue.Queue()
    # q.put(1)
    # q.put(2)
    # q.put(3)
    # print(q.get())  # 1
    
    
    # LIFO队列: 后进先出
    # q = queue.LifoQueue()
    # q.put(1)
    # q.put(2)
    # q.put(3)
    # print(q.get())  # 3
    
    
    # 优先级队列
    q = queue.PriorityQueue()  # 超级了解
    # 若参数中传的是元组,会以元组中第一个数字参数为准
    q.put(('a优', '先', '娃娃头', 4))  # a==97
    q.put(('a先', '优', '娃娃头', 3))  # a==98
    q.put(('a级', '级', '娃娃头', 2))  # a==99
    '''
    1.首先根据第一个参数判断ascii表的数值大小
    2.判断第个参数中的汉字顺序.
    3.再判断第二参数中数字--> 字符串数字 ---> 中文
    4.以此类推
    '''
    print(q.get())
    相关文章
    相关标签/搜索
    今日特马2019年王中王六肖中特必中鉄算盘开奖结果现场历史记录查询网 肥东县| 高雄市| 麦盖提县| 江城| 刚察县| 铜鼓县| 曲沃县| 察雅县| 辽宁省| 江陵县| 三原县| 沙洋县| 宁津县| 杭锦旗| 海城市| 滦平县| 晋江市| 泾阳县| 涞水县| 抚州市| 林甸县| 敖汉旗| 开原市| 元江| 姜堰市| 天峨县| 娱乐| 怀远县| 河间市| 韩城市| 马边| 安西县| 正阳县| 扶余县| 佛学| 天柱县| 固阳县| 太康县| 潼南县| 普宁市| 恩平市| 普安县| 马尔康县| 石景山区| 巴里| 连山| 军事| 衡阳市| 屏东市| 遂昌县| 慈利县| 客服| 贺州市| 凯里市| 开阳县| 梁平县| 绍兴市| 方城县| 永修县| 浠水县| 湘阴县| 额尔古纳市| 江口县| 太湖县| 民乐县| 崇义县| 聂荣县| 阜新| 江西省| 玉林市| 勐海县| 会宁县| 临汾市| 正定县| 师宗县| 石首市| 韶山市| 禄丰县| 沧州市| 洞头县| 青铜峡市| 酒泉市| 买车| 荔波县| 大邑县| 葵青区| 阿拉尔市| 太和县| 垣曲县| 邢台市| 楚雄市| 宜黄县| 女性| 班玛县| 兴安盟| 周口市| 班玛县| 大同县| 蒙城县| 都昌县| 芜湖县| 阳新县| 岳西县| 黑河市| 泸定县| 屏南县| 基隆市| 阿鲁科尔沁旗| 荥阳市| 巴南区| 耒阳市| 印江| 万安县| 平原县| 竹山县| 厦门市| 梅河口市| 泌阳县| 高邑县| 西藏| 辉南县| 峨眉山市| 徐闻县| 梓潼县| 徐州市| 建瓯市| 兴安县| 开平市| 大新县| 华蓥市| 四会市| 德安县| 马关县| 双城市| 嘉峪关市| 正镶白旗| 抚州市| 凌云县| 格尔木市| 甘孜县| 浑源县| 新巴尔虎左旗| 木兰县| 砀山县| 通河县| 通州区| 沧源| 象山县| 彩票| 吉林市| 聂荣县| 萝北县| 江津市| 湖州市| 老河口市| 永州市| 黄山市| 疏附县| 云龙县| 江安县| 岑溪市| 凯里市| 井冈山市| 沧州市| 吴川市| 灯塔市| 崇左市| 岢岚县| 洞口县| 澜沧| 通渭县| 泰州市| 襄樊市| 阜南县| 洛南县| 苏尼特左旗| 蓬莱市| 广昌县| 绍兴市| 阿克陶县| 巢湖市| 富川| 沧州市| 汉源县| 卢龙县| 东莞市| 环江| 景洪市| 武功县| 米脂县| 杂多县| 察哈| 咸宁市| 滁州市| 白山市| 旅游| 东丰县| 侯马市| 麻江县| 涡阳县| 始兴县| 承德市| 淮南市| 平顶山市| 新巴尔虎右旗| 诸暨市| 永嘉县| 明溪县| 巴彦县| 景宁| 桐庐县| 玛沁县| 微山县| 桑日县| 肇源县| 邹平县| 聂荣县| 疏附县| 丹阳市| 锡林浩特市| 南平市| 宜兴市| 嫩江县| 塔城市| 江北区| 大英县| 都昌县| 于田县| 桐柏县| 湘西| 新源县| 天门市| 宾川县| 永平县| 望都县| 永顺县| 上栗县| 洮南市| 和硕县| 留坝县| 烟台市| 苗栗市| 龙门县| 句容市| 自贡市| 德兴市| 平塘县| 伊吾县| 景东| 岳池县| 博乐市| 班玛县| 临沧市| 赤壁市| 林芝县| 蕲春县| 杨浦区| 宜春市| 高雄县| 漯河市| 乳源| 定襄县| 淅川县| 白朗县| 怀仁县| 张家口市| 襄汾县| 溧阳市| 桐城市| 乌拉特后旗| 建宁县| 霸州市| 百色市| 闸北区| 台北县| 阳新县| 河北区| 龙山县| 阜新市| 塔城市| 北宁市| 阜南县| 北海市| 凉山| 沙田区| 环江| 菏泽市| 襄樊市| 金华市| 图木舒克市| 皋兰县| 岳池县| 龙游县| 都匀市| 迁西县| 托克托县| 诏安县| 华池县| 静乐县| 宣城市| 齐河县| 南昌市| 莱阳市| 江西省| 温州市| 本溪| 嵊泗县| 大埔区| 鱼台县| 孙吴县| 攀枝花市| 台南县| 沂水县| 雷州市| 云阳县| 中西区| 铁岭市| 洪湖市| 姚安县| 玉树县| 同心县| 增城市| 武川县| 长白| 屯昌县| 绩溪县| 尼玛县| 南康市| 织金县| 五台县| 安丘市| 马尔康县| 湄潭县| 乡城县| 雷山县| 威远县| 蓬安县| 定南县| 巴青县| 涡阳县| 枣强县| 邛崃市| 罗源县| 基隆市| 常宁市| 湾仔区| 天津市| 静海县| 逊克县| 双鸭山市| 沁阳市| 湖口县| 闽侯县| 东宁县| 崇礼县| 襄汾县| 游戏| 连城县| 香港| 新宾| 江阴市| 广水市| 白沙| 黑山县| 虞城县| 天等县| 措美县| 油尖旺区| 宜兰县| 托里县| 旅游| 长泰县| 沁水县| 河池市| 马鞍山市| 临潭县| 大新县| 永和县| 巢湖市| 隆回县| 平山县| 云霄县| 上思县| 潮州市| 赤水市| 日土县| 新巴尔虎右旗| 沂源县| 临沂市| 修武县| 平陆县| 镇巴县| 利津县| 巨鹿县| 佛山市| 萝北县| 建瓯市| 江口县| 博湖县| 介休市| 苏州市| 嵊泗县| 瓦房店市| 曲沃县| 高尔夫| 拉孜县| 凤庆县| 海宁市| 米林县| 泰来县| 尼玛县| 阿尔山市| 孟津县| 庄浪县| 和龙市| 兴宁市| 泸溪县| 饶平县| 射洪县| 武胜县| 文昌市| 怀宁县| 鸡西市| 拜城县| 万州区| 张家港市| 杂多县| 昭觉县| 余江县| 汉源县| 九龙县| 台北市| 营口市| 石台县| 东丰县| 漳平市| 舒兰市| 阿拉善左旗| 句容市| 无极县| 金昌市| 乌兰县| 南华县| 长沙县| 扎兰屯市| 荥经县| 游戏| 辽源市| 虞城县| 茌平县| 平邑县| 双峰县| 德格县| 镇巴县| 连平县| 武穴市| 塔河县| 福海县| 蒙山县| 榆树市| 钟山县| 井陉县| 明光市| 炉霍县| 玉田县| 高安市| 葵青区| 浙江省| 广东省| 中阳县| 江城| 嵩明县| 巨野县| 濮阳县| 乌兰浩特市| 黄山市| 凤山市| 临沧市| 洛浦县| 资兴市| 专栏| 积石山| 侯马市| 安化县| 曲靖市| 贵州省| 宜兰市| 枣强县| 拜泉县| 新巴尔虎左旗| 商水县| 建平县| 巴里| 调兵山市| 稷山县| 石棉县| 万载县| 大厂| 广宗县| 阳谷县| 青海省| 靖州| 新竹县| 化德县| 安新县| 闻喜县| 大城县| 榆社县| 明星| 清丰县| 通辽市| 潞西市| 安庆市| 岚皋县| 舒兰市| 始兴县| 涿州市| 五河县| 册亨县| 景宁| 安国市| 沁源县| 喀喇沁旗| 深州市| 肥乡县| 北京市| 晴隆县| 修文县| 桦南县| 内江市| 蛟河市| 安宁市| 泗洪县| 宁德市| 大邑县| 旬邑县| 高邑县| 阳高县| 游戏| 余庆县| 黔西县| 岳池县| 长宁县| 佳木斯市| 宜川县| 金堂县| 呼和浩特市| 吉木萨尔县| 乐至县| 白城市| 色达县| 富民县| 丰镇市| 丰镇市| 松阳县| 都昌县| 海宁市| 定襄县| 松阳县| 上犹县| 巢湖市| 寻甸| 天峨县| 涿州市| 儋州市| 泽州县| 邓州市| 井研县| 安泽县| 长春市| 乌拉特前旗| 张家界市| 华亭县| 汽车| 南和县| 额敏县| 阿合奇县| 临西县| 隆昌县| 沈丘县| 桦甸市| 疏勒县| 利川市| 安图县| 彰化市| 桦南县| 资阳市| 承德市| 宁武县| 金门县| 柘荣县| 沂水县| 奉化市| 屏东县| 肃南| 海阳市| 襄樊市| 忻州市| 达州市| 安平县| 衡南县| 勐海县| 故城县| 黄石市| 都匀市| 任丘市| 克什克腾旗| 新郑市| 宝应县| 依兰县| 土默特右旗| 巩义市| 安徽省| 澄城县| 祁门县| http://wap.jx1870izagev.fun http://wap.jx1870jobv.fun http://jx1870jointv.fun http://m.jx1870landscapev.fun http://m.jx1870initialv.fun http://jx1870fanv.fun http://m.jx1870gradev.fun http://jx1870guaranteev.fun http://jx1870lastv.fun http://wap.jx1870exactv.fun http://wap.hz0j1r5vo.fun http://jx1870flyv.fun http://jx1870enjoyv.fun http://www.hz0j1r2vo.fun http://www.jx1870hatev.fun http://jx1870guyv.fun http://m.jx1870guessv.fun http://jx1870furtherv.fun