Python學習筆記之線程

from multiprocessing import Process
import time
import os
class MyProcess(Process):
    def __init__(self, name):  ##重寫，需要__init__,也添加瞭新的參數。        ##Process.__init__(self) 不可以省略，否則報錯：AttributeError:'XXXX'object has no attribute '_colsed'
        Process.__init__(self)
        self.name = name
    def run(self):
        print("子進程(%s-%s)啟動" % (self.name, os.getpid()))
        time.sleep(3)
        print("子進程(%s-%s)結束" % (self.name, os.getpid()))
if __name__ == '__main__':
    print("父進程啟動")
    p = MyProcess("Ail")
    # 自動調用MyProcess的run()方法
    p.start()
    p.join()
    print("父進程結束")

from threading import Thread
from multiprocessing import Process
import os
def work():
    print('hello,',os.getpid())
if __name__ == '__main__':
    # 在主進程下開啟多個線程，每個線程都跟主進程的pid一樣
    t1 = Thread(target=work)  # 開啟一個線程
    t2 = Thread(target=work)  # 開啟兩個線程
    t1.start()  ##start()--It must be called at most once per thread object.It arranges for the object's run() method to be                ## invoked in a separate thread of control.This method will raise a RuntimeError if called more than once on the                ## same thread object.
    t2.start()
    print('主線程/主進程pid', os.getpid())
    # 開多個進程，每個進程都有不同的pid
    p1 = Process(target=work)
    p2 = Process(target=work)
    p1.start()
    p2.start()
    print('主線程/主進程pid',os.getpid())

import time
import threading
class MyThread(threading.Thread):
    def __init__(self,num):
        super().__init__() ###或者是Thread.__init__()
        self.num = num
    def run(self):
        print('線程名稱：', threading.current_thread().getName(), '參數：', self.num, '開始時間：', time.strftime('%Y-%m-%d %H:%M:%S'))
if __name__ == '__main__':
    print('主線程開始：',time.strftime('%Y-%m-%d %H:%M:%S'))
    t1 = MyThread(1)
    t2 = MyThread(2)
    t1.start()
    t2.start()
    t1.join()
    t2.join()
    print('主線程結束：', time.strftime('%Y-%m-%d %H:%M:%S'))

from threading import Thread
from threading import Lock
import time
number = 0
def task(lock):
    global number
    lock.acquire() ##持有鎖
    for i in range(100000)      number += 1
    lock.release() ##釋放鎖
if __name__ == '__main__':
    lock=Lock()
    t1 = Thread(target=task,args=(lock,))
    t2 = Thread(target=task,args=(lock,))    t3 = Thread(target=task,args=(lock,))
    t1.start()    t2.start()    t3.start()    t1.join()    t2.join()    t3.join()        print('number:',number)

import time
import threading
s=threading.Semaphore(5)    #添加一個計數器
def task():
    s.acquire()    #計數器獲得鎖
    time.sleep(2)    #程序休眠2秒
    print("The task run at ",time.ctime())
    s.release()    #計數器釋放鎖

for i in range(40):
    t1=threading.Thread(target=task,args=())    #創建線程
    t1.start()    #啟動線程

import time
import threading
s=threading.Semaphore(5)    #添加一個計數器
def task():    with s:   ## 類似打開文件的with操作
    ##s.acquire()    #計數器獲得鎖
      time.sleep(2)    #程序休眠2秒
      print("The task run at ",time.ctime())
    ##s.release()    #計數器釋放鎖

for i in range(40):
    t1=threading.Thread(target=task,args=())    #創建線程
    t1.start()    #啟動線程