多线程专题

import time
import threading

-----------def sign():

----------- for i in range(0,3):

----------- print(f'唱第{i}====首歌')

----------- time.sleep(1)

-----------

-----------def dance():

----------- for i in range(0,3):

----------- print(f'跳第{i}====只舞')

----------- print("程序花费时间:",time.time()-start_time)

----------- time.sleep(1)

-----------

-----------

-----------##--start_time = time.time()

-----------##--sign()

-----------##--dance()

-----------##--print(time.time()-start_time)

-----------

-----------#把普通的函数对象转换成线程对象 只针对函数

-----------start_time = time.time()

-----------sign_thread = threading.Thread(target=sign) #target 函数任务目标

-----------print(sign_thread)

-----------#执行线程任务

-----------sign_thread.start()

-----------

-----------

-----------dance_thread = threading.Thread(target=dance) #target 函数任务目标

-----------print(dance_thread)

-----------#执行线程任务

-----------dance_thread.start()

多线程传参

def get(url,headers=None):
print(url)
time.sleep(3) ##阻塞
print(headers)

urls = ['https://www.baidu.com','https://www.guge.com','https://www.douban.com']

for url in urls:
get_thread = threading.Thread(
target = get, #传入函数的名字 转换对象
args=(url,), # args 指定函数的位置参数 如果只有一个 那么需要传入元组对象 就死加上逗号
kwargs = {'headers':{'user-agent':'Mozilla/5.0'}} ##传递了关键字参数

)

get_thread.start()

一个函数 只做一个功能 最理想的函数封装模式

发送请求

def send_requests(url):
response = requests.get(url)
return response

解析数据

def parse_data(data):
result = re.findall('',data,re.S)

保存数据

def save_data(filename,img_data): ##return None
with open ('img\' + filename , mode = 'wb' ) as f:
f.write(img_data)
print('正在保存---'+ title)

def main(url): ##总调度函数
html_data = send_requests(url=url).text

img_list = parse_data(html_data)

for img_url in img_list:
    filename  = img_url.split('/')[-1]  ##文件名
    img_data = send_requests(url=img_url).content

    save_data(filename,img_data)
print("程序花费时间:",time.time()-start_time)

当主函数写完以后 一定要运行 主函数是否有问题 只有没问题 才可以构建多线程 否则出错找不到

测试主函数

main('')

start_time = time.time()
for page in range(0,3): #10页码 主线程 + 所有线程 = 11个任务
url = f'{page}'

main_thread = threading.Thread(target=main,args=(url,))
main_thread.start()    

现在任务数据 不能用for循环实现 是不可以控制数量的

任务数量不是越多越好 是根据当前计算机性能实现 可以通过限制任务数量来解决 否则 丢包数据

敏感资源 全局变量 加锁 解锁

lock = threading.Lock()

with open('穷游.csv',mode='a',encoding='utf-8',newline='') as f:
csv_write = csv.writer(f)
for d in data:

--lock.acquire()加锁

csv_write.writerow(d)

--lock.release()解锁

lock = threading.Lock()

进程模块 ::: multiprocessing.Process
无法执行花费时间代码的 会报错
print("程序花费时间:",time.time()-start_time)
必须写在 if name == 'main':

解决丢包问题 启用线程池

import concurrent.futures ##导入了池子模块

if name == 'main':

#ThreadPoolExecutor 线程池对象
#ProcessPoolExecutor 进程池对象
# with concurrent.futures.ProcessPoolExecutor()
with concurrent.futures.ThreadPoolExecutor(max_workers=3) as  executor:
    for i in range(10):
    ##@@@@@submit  向池子添加任务  参数按照位置传递  用逗号分隔开
        executor.submit(thread_function,i)
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 219,635评论 6 508
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 93,628评论 3 396
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 165,971评论 0 356
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 58,986评论 1 295
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 68,006评论 6 394
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 51,784评论 1 307
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 40,475评论 3 420
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 39,364评论 0 276
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 45,860评论 1 317
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 38,008评论 3 338
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 40,152评论 1 351
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,829评论 5 346
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 41,490评论 3 331
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 32,035评论 0 22
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 33,156评论 1 272
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 48,428评论 3 373
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 45,127评论 2 356

推荐阅读更多精彩内容