学步园

queue = Queue.Queue( )
queue2 = Queue.Queue( )

class CThread(threading.Thread):
    def __init__( self, ipList ):
        threading.Thread.__init__( self )
        self.__ipList = ipList                     #需要ping的目标主机列表
        self.__nPackage = 1                     #ping目标主机发包数

    def run( self ):
        if sys.platform and sys.platform[:3]=='win':
            cmd = 'ping -n %d ' % (self.__nPackage)
        else:
            cmd = 'ping -c %d ' % (self.__nPackage)
        for ip in self.__ipList:
            print 'pinging %s' % ip
            sRst = os.popen( cmd+ip ).read( )
            if re.search( 'timeds*out', sRst ) and 
               (not re.match( 'ttl', sRst ) or 
                not re.match( 'TTL', sRst )):
                queue.put( ip )
            else:
                queue2.put( ip )

class CPing:
    def __init__( self, ipList ):
        self.__ipList = ipList                  #需要ping的目标主机列表
        self.__nThread = 50                     #开启的ping线程数

    def Ping( self ):
        nBegin = time.time( )
        listThread = []
        n = len(self.__ipList)/self.__nThread+1
        nSum = 0
        for i in range(self.__nThread):
            if i*n+n < len(self.__ipList):
                nSum += 1
                trd = CThread( self.__ipList[i*n:i*n+n] )
                print 'thread%d' % i, self.__ipList[i*n:i*n+n]
            else:
                if not self.__ipList[i*n:]:
                    break
                nSum += 1
                trd = CThread( self.__ipList[i*n:] )
                print 'thread%d' % i, self.__ipList[i*n:]
            listThread.append( trd )
            trd.start( )
        for i in range(nSum):
            listThread[i].join( )
        nEnd = time.time( )
        print '共用%d秒'.decode('utf-8') % (nEnd-nBegin)

def main( ):
    ipList = []
    for i in xrange( 11, 21 ):
        ipList.append( '192.168.0.'+str(i) )

    ping = CPing( ipList )
    ping.Ping( )
    print 'not connected:'
    while not queue.empty( ):
        print queue.get( )
    print 'connected:'
    while not queue2.empty( ):
        print queue2.get( )

if __name__ == '__main__':
    main( )