python 之 Threading 多线程((更新中)

# -*- coding: utf-8 -*-
import threading

def main():
    print(threading.active_count()) #运行的线程个数
    print(threading.enumerate()) #运行的是哪些线程
    print(threading.current_thread()) #当下运行的是哪个线程

if __name__ == ‘main‘:
    main()

# -*- coding: utf-8 -*-
import threading

def thread_job():
    print(‘This is an added Theard,number is %s‘ % threading.current_thread())

def main():
    added_thread = threading.Thread(target=thread_job)
    added_thread.start()

if __name__ == ‘main‘:
    main()

# -*- coding: utf-8 -*-
import threading
import time

def thread_job():
    print("T1 start\n")
    for i in range(10):
        time.sleep(0.1)
    print("T1 finish\n")

def main():
    added_thread = threading.Thread(target=thread_job,name="T1")
    added_thread.start()
    print("all done\n")

if __name__ == ‘main‘:
    main()

# -*- coding: utf-8 -*-
import threading
import time

def thread_job():
    print("T1 start\n")
    for i in range(10):
        time.sleep(0.1)
    print("T1 finish\n")

def main():
    added_thread = threading.Thread(target=thread_job,name="T1")
    added_thread.start()
    added_thread.join()
    print("all done\n")

if __name__ == ‘main‘:
    main()

# -*- coding: utf-8 -*-
import threading
import ti
def thread_job():
    print("T1 start\n")
    for i in range(10):
        time.sleep(0.1)
    print("T1 finish\n")

def thread_job2():
    print("T2 start\n")
    print("T2 finish\n")
    
def main():
    added_thread = threading.Thread(target=thread_job,name="T1")
    added_thread2 = threading.Thread(target=thread_job2,name="T2")
    added_thread.start()
    added_thread2.start()
    
    #added_thread.join()
　　 #added_thread2.join()

    print("all done\n")

if __name__ == ‘main‘:
    main()

# -*- coding: utf-8 -*-

import threading
from queue import Queue

def job(l,q):
    for i in range(len(l)):
        l[i] = l[i]**2
    q.put(l) #将计算结果放入q，不能用return
    
def multiThreading():
    q = Queue()
    threads=[] #装四个线程
    data = [[1,2,3],[4,5,6],[6,6,6],[8,8,8]]
    
    for i in range(4):#分别运行四个线程并传入参数
        t = threading.Thread(target=job,args=(data[i],q)) 
        t.start()
        threads.append(t)
        
    for thread in threads:
        thread.join()
        
    results=[] #将结果一个个取出到 results 并输出
    for _ in range(4):
        results.append(q.get())
    print(results)
        
    
if __name__=="__main__":
    multiThreading()