多线程

import _thread
import time

def print_time(threadName,delay):
    count = 0
    while count < 5:
        time.sleep(delay)
        count += 1
        print('{0}: {1}'.format(threadName,time.ctime(time.time())))

try:
    _thread.start_new_thread(print_time,('Thread-1',2,))
    _thread.start_new_thread(print_time,('Thread-2',4,))
except:
    print('Error')
while 1:
    pass

# 3-线程同步
import threading
import time
class 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('开启线程： ' + self.name)
        threadLock.acquire()
        print_time(self.name,self.counter,3)
        threadLock.release()

def print_time(threadName,delay,counter):
    while counter:
        time.sleep(delay)
        print('{} :{}'.format(threadName,time.ctime(time.time())))
        counter -=1

threadLock = threading.Lock()
threads  = []

thread1 = myThread(1,'Thread-1',1)
thread2 = myThread(2,'Thread-2',2)

thread1.start()
thread2.start()

threads.append(thread1)
threads.append(thread2)

for t in threads:
    t.join()
print('退出主线程')

# 线程优先级队列
import queue
import threading
import time

exitFlag = 0

class myThread (threading.Thread):
    def __init__(self,threadID,name,q):
        threading.Thread.__init__(self)
        self.thredID = threadID
        self.name = name
        self.q = q
    def run(self):
        print('开启线程：' + self.name)
        process_data(self.name,self.q)
        print('退出线程： ' + self.name)
def process_data(threadName,q):
    while not exitFlag:
        queueLock.acquire()
        if not workQueue.empty():
            data = q.get()
            queueLock.release()
            print('{}: {}'.format(threadName,data))
        else:
            queueLock.release()
        time.sleep(1)

threadList = ['Thread-1','Thread-2','Thread-3']
nameList = ['One','Two','Three','Four','Five']
queueLock = threading.Lock()
workQueue = queue.Queue(10)
threads = []
threadID = 1

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

queueLock.acquire()
for word in nameList:
    workQueue.put(word)
queueLock.release()

while not workQueue.empty():
    pass

exitFlag = 1

for t in threads:
    t.join()
print('退出主鼎城')

# 使用threading模块创建线程
import threading
import time

exitFlag = 0
class 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('开始线程： '+ self.name)
        print_time(self.name,self.counter,5)
        print('tichuxiancheng') + self.name

def print_time(threadName,delay,counter):
    while counter:
        if exitFlag:
             threadName.exit()
        time.sleep(delay)
        print('{}:{}'.format(threadName,time.ctime(time.time())))


thread1 = myThread(1,'Thread-1',1)
thread2 = myThread(2,'Thread-2',2)

thread1.start()
thread2.start()
thread1.join()
thread2.join()
print('退出主线程')