会python真的可以为所欲为0(回)
380天前
这里还有人吗1(回)
565天前这里还有人吗0(回)
565天前
每天面对着电脑屏幕，敲打键盘。我所面对的并不只是代码，而是一种生活方式。0(回)
789天前到处都是羊，不想上班0(回)
869天前
鸽子
0(回)
874天前""" |
多线程程序如果没有竞争资源处理起来通常也比较简单 |
当多个线程竞争临界资源的时候如果缺乏必要的保护措施就会导致数据错乱 |
说明：临界资源就是被多个线程竞争的资源 |
""" |
import time |
import threading |
from concurrent.futures import ThreadPoolExecutor |
class Account(object): |
"""银行账户""" |
def __init__(self): |
self.balance = 0.0 |
self.lock = threading.Lock() |
def deposit(self, money): |
# 通过锁保护临界资源 |
with self.lock: |
new_balance = self.balance + money |
time.sleep(0.001) |
self.balance = new_balance |
class AddMoneyThread(threading.Thread): |
"""自定义线程类""" |
def __init__(self, account, money): |
self.account = account |
self.money = money |
# 自定义线程的初始化方法中必须调用父类的初始化方法 |
super().__init__() |
def run(self): |
# 线程启动之后要执行的操作 |
self.account.deposit(self.money) |
def main(): |
"""主函数""" |
account = Account() |
# 创建线程池 |
pool = ThreadPoolExecutor(max_workers=10) |
futures = [] |
for _ in range(100): |
# 创建线程的第1种方式 |
# threading.Thread( |
# target=account.deposit, args=(1, ) |
# ).start() |
# 创建线程的第2种方式 |
# AddMoneyThread(account, 1).start() |
# 创建线程的第3种方式 |
# 调用线程池中的线程来执行特定的任务 |
future = pool.submit(account.deposit, 1) |
futures.append(future) |
# 关闭线程池 |
pool.shutdown() |
for future in futures: |
future.result() |
print(account.balance) |
if __name__ == '__main__': |
main() |
