通过ssh在多台Windows计算机上实现python的并行处理

import paramiko
from concurrent.futures import ThreadPoolExecutor

def execute_command(ssh, command):
    stdin, stdout, stderr = ssh.exec_command(command)
    return stdout.read().decode()

def run_remote_python_script(hostname, username, password, script_path):
    ssh = paramiko.SSHClient()
    ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
    ssh.connect(hostname, username=username, password=password)
    
    result = execute_command(ssh, f"python {script_path}")
    
    ssh.close()
    
    return result

def distribute_tasks(hostnames, username, password, script_path):
    results = []
    
    with ThreadPoolExecutor() as executor:
        for hostname in hostnames:
            result = executor.submit(run_remote_python_script, hostname, username, password, script_path)
            results.append(result)
    
    for result in results:
        print(result.result())

if __name__ == "__main__":
    hostnames = ["hostname1", "hostname2", "hostname3"]
    username = "your_username"
    password = "your_password"
    script_path = "path_to_your_python_script.py"
    
    distribute_tasks(hostnames, username, password, script_path)