Python多线程实现消费者实例

怼烎@ 2022-02-19 16:14 220阅读 0赞

结合Python多线程，和队列queue实现一个简单的队列消费者实例。用例批量检测ip是否存在。

from __future__ import print_function
    import subprocess
    import threading
    from queue import Queue
    from queue import Empty
    
    def call_ping(ip):
        try:
            # subprocess.check_call检查命令是否执行正确
            subprocess.check_call(['ping',ip], stdout=subprocess.PIPE)
            print("{} is alive".format(ip))
        except subprocess.CalledProcessError as e:
            print("{} is unreachable.".format(ip))
            print(e.output)
            # print(e.returncode)
    
    def is_reachable(q):
        try:
            while True:
                # q.get_nowait非阻塞从队列取出元素
                ip = q.get_nowait()
                call_ping(ip)
        except Empty:
            pass
    
    def main():
        # 使用queue定义一个队列缓冲区，避免频繁的上下文切换
        q = Queue()
        with open('ip.txt', 'r', encoding='utf-8') as f:
            for line in f.readlines():
                # put添加元素
                q.put(line.strip('\n'))
        threads = []
        for i in range(2):
            thr = threading.Thread(target=is_reachable, args=[q,])
            thr.start()
            threads.append(thr)
    
        for thr in threads:
            thr.join()
    
    if __name__ == '__main__':
        main()

发表评论取消回复

表情：

评论列表（有 0 条评论，220人围观）

还没有评论，来说两句吧...

相关阅读

相关 Java多线程同步问题：生产者消费者模型实例

在Java中，我们可以使用synchronized关键字以及相关的Lock接口来实现生产者消费者模型。这里提供一个简单的例子： 1. 创建两个类，一个代表产品（Product

向右看齐/ 2024年11月23日 09:45/ 0 赞/ 12 阅读

相关 Java多线程同步问题：生产者-消费者模型实例

在Java中实现生产者-消费者模型，通常我们会使用`synchronized`关键字、`Lock`接口或者`ReentrantLock`类来实现线程同步。以下是一个简单的例

我就是我/ 2024年09月10日 22:03/ 0 赞/ 83 阅读

相关 python实现多线程

使用Python实现调用子线程的子线程 import threading import time 孙线程 def grandchild_th

た入场券/ 2023年10月12日 08:26/ 0 赞/ 43 阅读

相关 C++ 实现多线程：生产者消费者模型

[C++ std::thread][C_ std_thread] 仓库用于存储生产好的产品，用循环数组来实现 1. 生产者：多个生产者之间互斥，当仓库满时等待，否

分手后的思念是犯贱/ 2023年08月17日 16:47/ 0 赞/ 155 阅读

相关 UNIX(多线程)：20---生产者消费者实例

本文将综合运用 C++11 中的新的基础设施(主要是多线程、锁、条件变量)来阐述一个经典问题——生产者消费者模型，并给出完整的解决方案。生产者消费者问题是多线程并发中一个非

女爷i/ 2023年01月08日 11:25/ 0 赞/ 91 阅读

相关 kafka多线程实现消费者实战

前言：KafkaProducer是线程安全的，但是KafkaConsumer不是线程安全的，同一个KafkaConsumer用在了多个线程中，将会报Kafka Consumer

Love The Way You Lie/ 2022年09月12日 15:52/ 0 赞/ 190 阅读

相关多线程实现消费者生产者的例子

今天看书，看了一个例子，于是自己手动的自己敲了一下。。。但是，期望的结果和理论结果是不一样的，求解答啊。。。上源代ma \[cpp\] [view plain][]

不念不忘少年蓝@/ 2022年08月23日 08:29/ 0 赞/ 183 阅读

相关 Java——生产者消费者多线程实现

/ 生产者消费者问题，这里实现的是生产一个，消费一个，生产一个，消费一个生产者有生产任务消费者有消费任务生产和消费可以同时执行所以使用多线程需要描述生产任务

亦凉/ 2022年06月07日 05:10/ 0 赞/ 270 阅读

相关 java多线程实现生产者消费者场景

商店 public class Tmall { private int count; public final

小鱼儿/ 2022年05月28日 03:08/ 0 赞/ 205 阅读

相关 Python多线程实现消费者实例

结合Python多线程，和队列queue实现一个简单的队列消费者实例。用例批量检测ip是否存在。 from __future__ import print_funct

怼烎@/ 2022年02月19日 16:14/ 0 赞/ 221 阅读