python线程同步,python线程,#!/usr/bin/p


#!/usr/bin/pythonimport threadingimport timeclass myThread (threading.Thread):    def __init__(self, threadID, name, counter):        threading.Thread.__init__(self)        self.threadID = threadID        self.name = name        self.counter = counter    def run(self):        print "Starting " + self.name        # Get lock to synchronize threads        threadLock.acquire()        print_time(self.name, self.counter, 3)        # Free lock to release next thread        threadLock.release()def print_time(threadName, delay, counter):    while counter:        time.sleep(delay)        print "%s: %s" % (threadName, time.ctime(time.time()))        counter -= 1threadLock = threading.Lock()threads = []# Create new threadsthread1 = myThread(1, "Thread-1", 1)thread2 = myThread(2, "Thread-2", 2)# Start new Threadsthread1.start()thread2.start()# Add threads to thread listthreads.append(thread1)threads.append(thread2)# Wait for all threads to completefor t in threads:    t.join()print "Exiting Main Thread"
                                输出结果
Starting Thread-1Starting Thread-2Thread-1: Thu Mar 21 09:11:28 2013Thread-1: Thu Mar 21 09:11:29 2013Thread-1: Thu Mar 21 09:11:30 2013Thread-2: Thu Mar 21 09:11:32 2013Thread-2: Thu Mar 21 09:11:34 2013Thread-2: Thu Mar 21 09:11:36 2013Exiting Main Thread

评论关闭