#!/usr/bin/python
# -*- coding: UTF-8 -*-

import threading    #導(dǎo)入threading 模塊
import time

# 定義任務(wù)函數(shù) print_time
def print_time ( threadName ,delay ):
    count = 0
    while count < 5:
        time.sleep(delay)
        count += 1
        print("%s: %s \n" % (threadName,time.ctime(time.time())))

# 定義任務(wù)函數(shù) print_cube
def print_cube(num):
    #pring cube
    print("Cube:{} \n".format(num*num*num))
 
# 創(chuàng)建兩個(gè)線程
if __name__ == "__main__":
        # 創(chuàng)建兩個(gè)子線程
        t1 = threading.Thread( target=print_cube,args=(10,))
        t2 = threading.Thread( target=print_time,args=("Thread-2",4,))
        #start threads
        t1.start()   # start 后，子線程開(kāi)始運(yùn)行
        t2.start()
        t1.join()     #join 命令：讓主線程暫停運(yùn)行，等待子線程運(yùn)行結(jié)束。
        t2.join()
        print("Done") # The statement is executed after sub threads done

class CountdownTask:
      
    def __init__(self):
          self._running = True   # 定義線程狀態(tài)變量
      
	def terminate(self):
	    self._running = False 
	      
	def run(self, n):
	    # run方法的主循環(huán)條件加入對(duì)狀態(tài)變量的判斷
	    while self._running and n > 0:
	        print('T-minus', n)
	        n -= 1
	        time.sleep(5)
	    print("thread is ended") 
  
c = CountdownTask()
th = Thread(target = c.run, args =(10, ))
th.start()
# 對(duì)于耗時(shí)線程，沒(méi)必要再用join()方法了，注意主線程通常也需要有個(gè)監(jiān)控循環(huán)
# … any code … 
# Signal termination
q = input("please press any key to quit ")
c.terminate() 

import threading
import time
 
def run():
    while True:
        print('thread running')
        global stop_threads
        if stop_threads:
            break
 
stop_threads = False
t1 = threading.Thread(target = run)
t1.start()
time.sleep(1)
stop_threads = True
t1.join()
print('thread killed')

if event.is_set():
     # do something before end worker 
     break

from time import sleep
from threading import Thread
from threading import Event
 
# define task function
def task(event):
    # execute a task in a loop
    for i in range(100):
        # block for a moment
        sleep(1)
        # check for stop
        if event.is_set():
            # 在此添加退出前要做的工作，如保存文件等
            break
        # report a message
        print('Worker thread running...')
    print('Worker is ended')
 
# create the event
event = Event()
# create a thread 
thread = Thread(target=task, args=(event,))
# start the new thread
thread.start()
# block for a while
sleep(3)
# stop the worker thread
print('Main stopping thread')
event.set()
# 這里是為了演示，實(shí)際開(kāi)發(fā)時(shí)，主進(jìn)程有事件循環(huán)，耗時(shí)函數(shù)不需要調(diào)用join()方法
thread.join()