from random import randint
from time import time, sleepdef download_task(filename):print('开始下载%s...' % filename)time_to_download = randint(5, 10)sleep(time_to_download)print('%s下载完成! 耗费了%d秒' % (filename, time_to_download))def main():start = time()download_task('Python从入门到住院.pdf')download_task('Peking Hot.avi')end = time()print('总共耗费了%.2f秒.' % (end - start))if __name__ == '__main__':main()复制代码

开始下载Python从入门到住院.pdf...
Python从入门到住院.pdf下载完成! 耗费了6秒
开始下载Peking Hot.avi...
Peking Hot.avi下载完成! 耗费了7秒
总共耗费了13.01秒.复制代码

from multiprocessing import Process
from os import getpid
from random import randint
from time import time, sleepdef download_task(filename):print('启动下载进程，进程号[%d].' % getpid())print('开始下载%s...' % filename)time_to_download = randint(5, 10)sleep(time_to_download)print('%s下载完成! 耗费了%d秒' % (filename, time_to_download))def main():start = time()p1 = Process(target=download_task, args=('Python从入门到住院.pdf', ))p1.start()p2 = Process(target=download_task, args=('Peking Hot.avi', ))p2.start()p1.join()p2.join()end = time()print('总共耗费了%.2f秒.' % (end - start))if __name__ == '__main__':main()复制代码

启动下载进程，进程号[1530].
开始下载Python从入门到住院.pdf...
启动下载进程，进程号[1531].
开始下载Peking Hot.avi...
Peking Hot.avi下载完成! 耗费了7秒
Python从入门到住院.pdf下载完成! 耗费了10秒
总共耗费了10.01秒.复制代码

from multiprocessing import Process
from time import sleepcounter = 0def sub_task(string):global counterwhile counter < 10:print(string, end='', flush=True)counter += 1sleep(0.01)def main():Process(target=sub_task, args=('Ping', )).start()Process(target=sub_task, args=('Pong', )).start()if __name__ == '__main__':main()复制代码

from random import randint
from threading import Thread
from time import time, sleepdef download(filename):print('开始下载%s...' % filename)time_to_download = randint(5, 10)sleep(time_to_download)print('%s下载完成! 耗费了%d秒' % (filename, time_to_download))def main():start = time()t1 = Thread(target=download, args=('Python从入门到住院.pdf',))t1.start()t2 = Thread(target=download, args=('Peking Hot.avi',))t2.start()t1.join()t2.join()end = time()print('总共耗费了%.3f秒' % (end - start))if __name__ == '__main__':main()复制代码

from random import randint
from threading import Thread
from time import time, sleepclass DownloadTask(Thread):def __init__(self, filename):super().__init__()self._filename = filenamedef run(self):print('开始下载%s...' % self._filename)time_to_download = randint(5, 10)sleep(time_to_download)print('%s下载完成! 耗费了%d秒' % (self._filename, time_to_download))def main():start = time()t1 = DownloadTask('Python从入门到住院.pdf')t1.start()t2 = DownloadTask('Peking Hot.avi')t2.start()t1.join()t2.join()end = time()print('总共耗费了%.2f秒.' % (end - start))if __name__ == '__main__':main()复制代码

from time import sleep
from threading import Threadclass Account(object):def __init__(self):self._balance = 0def deposit(self, money):# 计算存款后的余额new_balance = self._balance + money# 模拟受理存款业务需要0.01秒的时间sleep(0.01)# 修改账户余额self._balance = new_balance@propertydef balance(self):return self._balanceclass AddMoneyThread(Thread):def __init__(self, account, money):super().__init__()self._account = accountself._money = moneydef run(self):self._account.deposit(self._money)def main():account = Account()threads = []# 创建100个存款的线程向同一个账户中存钱for _ in range(100):t = AddMoneyThread(account, 1)threads.append(t)t.start()# 等所有存款的线程都执行完毕for t in threads:t.join()print('账户余额为: ￥%d元' % account.balance)if __name__ == '__main__':main()复制代码

from time import sleep
from threading import Thread, Lockclass Account(object):def __init__(self):self._balance = 0self._lock = Lock()def deposit(self, money):# 先获取锁才能执行后续的代码self._lock.acquire()try:new_balance = self._balance + moneysleep(0.01)self._balance = new_balancefinally:# 在finally中执行释放锁的操作保证正常异常锁都能释放self._lock.release()@propertydef balance(self):return self._balanceclass AddMoneyThread(Thread):def __init__(self, account, money):super().__init__()self._account = accountself._money = moneydef run(self):self._account.deposit(self._money)def main():account = Account()threads = []for _ in range(100):t = AddMoneyThread(account, 1)threads.append(t)t.start()for t in threads:t.join()print('账户余额为: ￥%d元' % account.balance)if __name__ == '__main__':main()复制代码

import time
import tkinter
import tkinter.messageboxdef download():# 模拟下载任务需要花费10秒钟时间time.sleep(10)tkinter.messagebox.showinfo('提示', '下载完成!')def show_about():tkinter.messagebox.showinfo('关于', '作者: 骆昊(v1.0)')def main():top = tkinter.Tk()top.title('单线程')top.geometry('200x150')top.wm_attributes('-topmost', True)panel = tkinter.Frame(top)button1 = tkinter.Button(panel, text='下载', command=download)button1.pack(side='left')button2 = tkinter.Button(panel, text='关于', command=show_about)button2.pack(side='right')panel.pack(side='bottom')tkinter.mainloop()if __name__ == '__main__':main()复制代码

import time
import tkinter
import tkinter.messagebox
from threading import Threaddef main():class DownloadTaskHandler(Thread):def run(self):time.sleep(10)tkinter.messagebox.showinfo('提示', '下载完成!')# 启用下载按钮button1.config(state=tkinter.NORMAL)def download():# 禁用下载按钮button1.config(state=tkinter.DISABLED)# 通过daemon参数将线程设置为守护线程(主程序退出就不再保留执行)# 在线程中处理耗时间的下载任务DownloadTaskHandler(daemon=True).start()def show_about():tkinter.messagebox.showinfo('关于', '作者: 骆昊(v1.0)')top = tkinter.Tk()top.title('单线程')top.geometry('200x150')top.wm_attributes('-topmost', 1)panel = tkinter.Frame(top)button1 = tkinter.Button(panel, text='下载', command=download)button1.pack(side='left')button2 = tkinter.Button(panel, text='关于', command=show_about)button2.pack(side='right')panel.pack(side='bottom')tkinter.mainloop()if __name__ == '__main__':main()复制代码

from time import timedef main():total = 0number_list = [x for x in range(1, 100000001)]start = time()for number in number_list:total += numberprint(total)end = time()print('Execution time: %.3fs' % (end - start))if __name__ == '__main__':main()复制代码

from multiprocessing import Process, Queue
from random import randint
from time import timedef task_handler(curr_list, result_queue):total = 0for number in curr_list:total += numberresult_queue.put(total)def main():processes = []number_list = [x for x in range(1, 100000001)]result_queue = Queue()index = 0# 启动8个进程将数据切片后进行运算for _ in range(8):p = Process(target=task_handler,args=(number_list[index:index + 12500000], result_queue))index += 12500000processes.append(p)p.start()# 开始记录所有进程执行完成花费的时间start = time()for p in processes:p.join()# 合并执行结果total = 0while not result_queue.empty():total += result_queue.get()print(total)end = time()print('Execution time: ', (end - start), 's', sep='')if __name__ == '__main__':main()复制代码