Python Ping脚本：如何结合subprocess实现多线程/多进程提速？

核心思路 #

Ping属于IO密集型操作，多线程（开销更低）或多进程都能大幅提升批量检测速度。subprocess屏蔽控制台输出只需将stdout和stderr重定向到DEVNULL，和多线程/多进程结合无冲突。

多线程实现示例 #

import threading
import subprocess
import os
from queue import Queue

def ping_host(host, result_queue):
    # 适配Windows/Linux的ping参数
    param = '-n' if os.name == 'nt' else '-c'
    # 执行ping命令，屏蔽输出
    result = subprocess.run(
        ['ping', param, '1', host],
        stdout=subprocess.DEVNULL,
        stderr=subprocess.DEVNULL,
        timeout=5  # 设置超时避免卡死
    )
    # 将检测结果存入队列
    status = "在线" if result.returncode == 0 else "离线"
    result_queue.put((host, status))

def batch_ping(hosts):
    result_queue = Queue()
    threads = []
    # 创建线程，控制并发数（建议20-50，避免资源过载）
    max_threads = 30
    for host in hosts:
        # 线程数满时等待
        while len(threads) >= max_threads:
            for t in threads:
                if not t.is_alive():
                    threads.remove(t)
        t = threading.Thread(target=ping_host, args=(host, result_queue))
        t.start()
        threads.append(t)
    # 等待所有线程结束
    for t in threads:
        t.join()
    # 收集结果
    results = []
    while not result_queue.empty():
        results.append(result_queue.get())
    return results

# 测试调用
if __name__ == "__main__":
    host_list = [f"192.168.1.{i}" for i in range(1, 201)]
    results = batch_ping(host_list)
    for host, status in results:
        print(f"{host}: {status}")

多进程实现示例 #

如果需要更彻底的资源隔离（比如担心线程GIL影响），可以用多进程：

import multiprocessing
import subprocess
import os

def ping_host(host):
    param = '-n' if os.name == 'nt' else '-c'
    result = subprocess.run(
        ['ping', param, '1', host],
        stdout=subprocess.DEVNULL,
        stderr=subprocess.DEVNULL,
        timeout=5
    )
    return (host, "在线" if result.returncode == 0 else "离线")

def batch_ping(hosts):
    # 进程池大小建议和CPU核心数匹配或稍高
    pool_size = multiprocessing.cpu_count() * 2
    with multiprocessing.Pool(pool_size) as pool:
        results = pool.map(ping_host, hosts)
    return results

# 测试调用
if __name__ == "__main__":
    host_list = [f"192.168.1.{i}" for i in range(1, 201)]
    results = batch_ping(host_list)
    for host, status in results:
        print(f"{host}: {status}")

关键注意事项 #

• 并发数控制：线程/进程数不要设置过大，否则会导致系统网络或进程调度过载，建议20-50线程，或CPU核心数2-4倍的进程数。
• 超时设置：必须给subprocess.run加timeout参数，避免个别主机无响应导致整个脚本卡住。
• 跨平台兼容：Windows和Linux的ping命令参数不同，通过os.name判断适配。

内容的提问来源于stack exchange，提问作者Alek Bass