python 通过threading多线

#!/usr/bin/env python #coding=utf-8 import paramiko import time,datetime,threading def ssh(ip,user,passwd,command):     ssh = paramiko.SSHClient()     ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())     try:         ssh.connect(ip,port=16333,username=user,password=passwd)     except paramiko.AuthenticationException:         #print "验证失败，用户名或密码错误."         return 0     except:         #print 'ip',"主机不可达。"         return 2     stdin, stdout, stderr = ssh.exec_command(command)     lines = [line.strip() for line in stdout.readlines()]     data_include_firstline = "".join(lines)     data_no_firstline = "".join(lines[1:])     return data_include_firstline def sshcmd(src,linerange):      i = 0     for line in open(src):         i += 1         if i in range(linerange[0],linerange[1]+1):              ip = line.strip()             user = 'root'             port = 16333             passwd = '123qwe'             command = 'hostname'             result = ssh(ip,user,passwd,command)             if result == 0:                 result = '验证失败，用户名或密码错误.'             elif result == 2:                 result = '主机不可达.'             print i,ip,result def main(num,src):     global count, mutex     linesum = sum(1 for line in open(src))     quotient = linesum/num     threads = []     # 创建一个锁     mutex = threading.Lock()     # 先创建线程对象     for k in xrange(1, num+1):         if k == num:             linerange = quotient*(k-1)+1,linesum         else:             linerange = quotient*(k-1)+1,quotient*k         threads.append(threading.Thread(target=sshcmd, args=(src,linerange)))     # 启动所有线程     for t in threads:         t.start()     # 主线程中等待所有子线程退出     for t in threads:         t.join()   starttime = datetime.datetime.now()  if __name__ == '__main__':     # 创建10个线程     main(10,'ip.txt') endtime = datetime.datetime.now() print "time span",endtime-starttime