Python2多线程

#!/usr/bin/python

import Queue
import threading
import time
import os
import sys
import socket
exitFlag = False
f = open(sys.argv[1])
marylines = f.readlines()
f.close()
countttter = threading.Lock()
countttterssss=0
tottttt = len(marylines)
class myThread (threading.Thread):
   def __init__(self, threadID, name, q):
        threading.Thread.__init__(self)
        self.threadID = threadID
        self.name = name
        self.q = q
   def run(self):
        print "Starting " + self.name
        process_data(self.name, self.q)
        print "Exiting " + self.name

def process_data(threadName, q):
   while not exitFlag:
        queueLock.acquire()
        if not workQueue.empty():
            data = q.get()
            queueLock.release()
            print "%s processing %s" % (threadName, data)
            #print data
            try:
                socket.gethostbyname(data.strip())
                filelock.acquire()
                ssssssssssssf = open(sys.argv[3],'a')
                ssssssssssssf.write(data)
                ssssssssssssf.close()
                filelock.release()

            except socket.gaierror:
                print "unable to get address for: ", data
            countttter.acquire()
            global countttterssss
            countttterssss = countttterssss + 1
            print  str(countttterssss) + '-----------------------------' + str(tottttt) + '\n'
            countttter.release()
        else:
            queueLock.release()
       # time.sleep(1)
threadList= []
for fuck in range(0,int(sys.argv[2])):
    threadList.append("Thread-"+str(fuck))
#threadList = ["Thread-1", "Thread-2", "Thread-3"]
#nameList = ["One", "Two", "Three", "Four", "Five"]
queueLock = threading.Lock()
filelock = threading.Lock()
workQueue = Queue.Queue(len(marylines))
threads = []
threadID = 1

# Create new threads
for tName in threadList:
    thread = myThread(threadID, tName, workQueue)
    thread.start()
    threads.append(thread)
    threadID += 1

# Fill the queue
queueLock.acquire()
for word in marylines:
    workQueue.put(word)
queueLock.release()

# Wait for queue to empty
while not workQueue.empty():
    pass

# Notify threads it's time to exit

exitFlag = True

# Wait for all threads to complete
for t in threads:
    t.join()
print "Exiting Main Thread"