《數(shù)據(jù)采集技術(shù)》課件-Python 內(nèi)置庫：threading 多線程

Python內(nèi)置庫：threading多線程threading庫線程是輕量級的，與進(jìn)程相比，線程的創(chuàng)建和管理更加方便，在并發(fā)編程中線程非常重要。是Python內(nèi)置庫中的一個(gè)模塊提供一些簡單的線程控制機(jī)制實(shí)現(xiàn)多線程編程threading庫可以創(chuàng)建多個(gè)線程，對于線程的狀態(tài)進(jìn)行控制，等待線程結(jié)束，同步線程等。提供了Thread類提供了其他的方法和類用于管理線程，實(shí)現(xiàn)線程同步等。線程基礎(chǔ)概念線程定義線程是操作系統(tǒng)能夠進(jìn)行運(yùn)算調(diào)度的最小單位，是進(jìn)程中的一個(gè)實(shí)體，作為系統(tǒng)調(diào)度和分派的基本單元。線程是進(jìn)程中的一個(gè)相對獨(dú)立的可執(zhí)行的單元，是程序執(zhí)行流的最小單元。指的是進(jìn)程中一個(gè)單一順序的控制流一條線程一個(gè)進(jìn)程中可以并發(fā)多個(gè)線程，每條線程并行執(zhí)行不同的任務(wù)。線程基礎(chǔ)概念一個(gè)線程有三種狀態(tài)：新狀態(tài)就緒狀態(tài)阻塞狀態(tài)處于新狀態(tài)當(dāng)線程被創(chuàng)建后就進(jìn)入了就緒狀態(tài)當(dāng)線程被調(diào)度并分配到CPU上時(shí)就進(jìn)入了阻塞狀態(tài)當(dāng)線程因等待某個(gè)條件發(fā)生而無法繼續(xù)執(zhí)行時(shí)線程基礎(chǔ)概念與進(jìn)程的區(qū)別：是指從軟件或者硬件上實(shí)現(xiàn)多個(gè)線程并發(fā)執(zhí)行的技術(shù)。是資源分配的最小單位進(jìn)程是程序執(zhí)行的最小單位線程多線程因有硬件支持而能夠在同一時(shí)間執(zhí)行多于一個(gè)線程，進(jìn)而提升整體處理性能。具有多個(gè)線程能力的計(jì)算機(jī)創(chuàng)建線程的方法及步驟創(chuàng)建線程的方法主要有兩種：繼承Thread類實(shí)現(xiàn)Runnable接口在Thread類的子類中重寫Thread類中的run()方法，設(shè)置線程任務(wù)。run()方法是線程執(zhí)行的入口點(diǎn)，其中包含線程要執(zhí)行的代碼。通過繼承Thread類創(chuàng)建線程，創(chuàng)建一個(gè)Thread類的子類。創(chuàng)建Thread類的子類的實(shí)例，并調(diào)用其start()方法啟動(dòng)線程。start()方法會(huì)調(diào)用run()方法，并開啟一個(gè)新的線程來執(zhí)行run()方法中的代碼。創(chuàng)建線程的方法及步驟創(chuàng)建線程的步驟：導(dǎo)入Thread模塊。1創(chuàng)建一個(gè)Thread類的子類，并重寫其run()方法。2創(chuàng)建Thread類的子類的實(shí)例，并調(diào)用其start()方法啟動(dòng)線程。3創(chuàng)建線程的方法及步驟在Thread類的子類中重寫Thread類中的run()方法，設(shè)置線程任務(wù)。run()方法是線程執(zhí)行的入口點(diǎn)，其中包含線程要執(zhí)行的代碼。通過繼承Thread類創(chuàng)建線程，創(chuàng)建一個(gè)Thread類的子類。創(chuàng)建Thread類的子類的實(shí)例，并調(diào)用其start()方法啟動(dòng)線程。start()方法會(huì)調(diào)用run()方法，并開啟一個(gè)新的線程來執(zhí)行run()方法中的代碼。創(chuàng)建線程的方法及步驟并調(diào)用其start()方法啟動(dòng)線程。start()方法會(huì)調(diào)用run()方法，并開啟一個(gè)新的線程來執(zhí)行run()方法中的代碼。創(chuàng)建Thread類的子類的實(shí)例導(dǎo)入Thread模塊。1創(chuàng)建一個(gè)Thread類的子類，并重寫其run()方法。2創(chuàng)建Thread類的子類的實(shí)例，并調(diào)用其start()方法啟動(dòng)線程。3創(chuàng)建線程的步驟：創(chuàng)建線程的方法及步驟示例1：importthreadingimporttime

defworker(num):print(f"Worker{num}starting")time.sleep(2)print(f"Worker{num}finished")returnnum*numt1=threading.Thread(target=worker,args=(1,))t2=threading.Thread(target=worker,args=(2,))t1.start()t2.start()運(yùn)行結(jié)果：Worker1startingWorker2startingWorker1finishedWorker2finished線程同步當(dāng)有一個(gè)線程在對內(nèi)存進(jìn)行操作時(shí)，其他線程都不可以對這個(gè)內(nèi)存地址進(jìn)行操作。定義：完成操作該線程才能進(jìn)行操作其他線程其他線程又處于等待狀態(tài)。線程同步當(dāng)有一個(gè)線程在對內(nèi)存進(jìn)行操作時(shí)，其他線程都不可以對這個(gè)內(nèi)存地址進(jìn)行操作。定義：完成操作一個(gè)線程才能進(jìn)行操作其他線程其他線程又處于等待狀態(tài)。線程同步確保多個(gè)線程能按照某種特定的方式正確、有序地執(zhí)行，避免并發(fā)問題。效果：鎖死競態(tài)條件資源可以使用鎖（Lock）實(shí)現(xiàn)同步。如：本講小結(jié)threading多線程1線程的創(chuàng)建方法及實(shí)現(xiàn)步驟2線程同步3課后作業(yè)使用線程來并行打印從1到100