import threading
from queue import Queue #Thread 無法回傳值，所以要使用 Queue.put() 將要傳回的值存入 Queue，再用 Queue.get() 取出
import time
import os

# ----------------------------------------範例1------------------------------
# A報數
def A_Count_off():
    for i in range(0,5):
        print(f'A : {i}')
        time.sleep(0.5)


# B報數
def B_Count_off():
    for i in range(5,10):
        print(f'B : {i}')
        time.sleep(0.5)



thread_list=[A_Count_off,B_Count_off]
thread_num =[]
# for i in range(0,len(thread_list)):
#     thread_num.append(threading.Thread(target=thread_list[i]))
#
# for i in range(0,len(thread_num)):
#     thread_num[i].start()
#     # thread_num[i].join()
#
# for i in range(0,len(thread_num)):
#     thread_num[i].join()



# ----------------------------------------範例2------------------------------

def Count_off(code_name):
    print('process {} '.format(os.getpid()))
    print('thread {} '.format(threading.current_thread().name))
    for i in range(0,5):
        print(f'{code_name} : {i}')
        time.sleep(0.5)


thread_name_list=["A","B","C","D"]

thread_list=[]
# for i in range(0,len(thread_name_list)):
#     thread_list.append(threading.Thread(target=Count_off,args=thread_name_list[i]))
# for i in range(0,len(thread_list)):
#     thread_list[i].start()
# for i in range(0,len(thread_list)):
#     thread_list[i].join()



# ----------------------------------------範例3------------------------------

class Thread_class(threading.Thread):
    def __init__(self,code_name):
        threading.Thread.__init__(self)
        self.code_name = code_name

    def run(self):
        print('process {} '.format(os.getpid()))  # 查看進程
        print('thread {} '.format(threading.current_thread().name))  # 查看線程
        for i in range(0,5):
            print(f'{self.code_name} : {i}')
            time.sleep(0.5)
    def test_return(self):
        return(f'{self.code_name}=END')



thread_name_list=["A","B","C","D"]
thread_list=[]
for i in range(0,len(thread_name_list)):
    thread_list.append(Thread_class(thread_name_list[i]))
for i in range(0,len(thread_list)):
    thread_list[i].start()
for i in range(0,len(thread_list)):
    thread_list[i].join()

for i in range(0,len(thread_list)):
    print(thread_list[i].test_return())