美文网首页
2019实战第二期-时间读书打卡

2019实战第二期-时间读书打卡

作者: tipire | 来源:发表于2019-03-30 23:23 被阅读0次

    2019实战第二期-时间读书打卡

    --读《Python编程快速上手—让繁琐工作自动化》

    Python里面的并发分2大类,cpu密集和IO密集,也是面试中经常考的!
    多进程,多线程,协程!围绕的库大概有6-7种,如果深入研究会设计到Py3里面最核心的也是最难懂的asyncio库,然而,初学者不需要知道这么多!
    简单会用就行,不要一口吃个胖子!
    我先把标签建好,详细参考这本"Python编程快速上手"第15章里面15.6/7/8小节
    这里就是一个多线程的启动,使用和停止!菜鸟先会用多线程足够了!
    等后面再慢慢学习多进程,协程!

    不必让所有的代码等待,直到 time.sleep()函数完成,你可以使用 Python 的threading 模块,在单独的线程中执行延迟或安排的代码。这个单独的线程将因为time.sleep()调用而暂停。同时,程序可以在原来的线程中做其他工作。

    要得到单独的线程,首先要调用 threading.Thread()函数,生成一个 Thread 对象。在新的文件中输入以下代码,并保存为 threadDemo.py:

    import threading, time
    print('Start of program.')
    
    def takeANap():
        time.sleep(5)
        print('Wake up!')
        
    threadObj = threading.Thread(target=takeANap)
    threadObj.start()
    
    print('End of program.')
    

    1、我们定义了一个函数,希望用于新线程中。为了创建一个 Thread 对象,我们调用 threading.Thread(),并传入关键字参数 target=takeANap

    2、我们要在新线程中调用的函数是 takeANap()。请注意,关键字参数是 target=takeANap,而不是 target=takeANap()。这是因为你想将 takeANap()函数本身作为参数,而不是调用 takeANap(),并传入它的返回值。

    3、 threading.Thread()创建的 Thread 对象保存在 threadObj 中,然后调用threadObj.start()

    向线程的目标函数传递参数

    threading.Thread()创建的 Thread 对象保存在 threadObj 中,然后调用threadObj.start()

    import threading
    threadObj = threading.Thread(target=print, args=['Cats', 'Dogs', 'Frogs'],kwargs={'sep': ' & '})
    threadObj.start()
    

    threadObj.start()调用将创建一个新线程来调用 print()函数,它会传入'Cats'、'Dogs'和'Frogs'作为参数,以及' & '作为 sep 关键字参数。

    并发问题

    1、如果这些线程同时读写变量,导致互相干扰,就会发生并发问题

    2、并发问题可能很难一致地重现,所以难以调试。

    为了避免并发问题,绝不让多个线程读取或写入相同的变量。当创建一个新的Thread 对象时,要确保其目标函数只使用该函数中的局部变量。这将避免程序中难以调试的并发问题。

    项目:多线程XKCD下载程序

    调用 downloadXkcd(140,280)将循环执行下载代码,下载漫画 http://xkcd.com/140http://xkcd.com/141http://xkcd.com/142 等,直到http://xkcd.com/279。你创建的每个线程都会调用 downloadXkcd(),并传入不同范围的漫画进行下载。

    #! python3
    # multidownloadXkcd.py - Downloads XKCD comics using multiple threads.
    import requests, os, bs4, threading
    os.makedirs('xkcd', exist_ok=True) # store comics in ./xkcd
    
    def downloadXkcd(startComic, endComic):
        for urlNumber in range(startComic, endComic):
            # Download the page.
            print('Downloading page http://xkcd.com/%s...' % (urlNumber))
            res = requests.get('http://xkcd.com/%s' % (urlNumber))
            res.raise_for_status()
            soup = bs4.BeautifulSoup(res.text)
            # Find the URL of the comic image.
            comicElem = soup.select('#comic img')
            if comicElem == []:
                print('Could not find comic image.')
            else:
                comicUrl = comicElem[0].get('src')
                # Download the image.
                print('Downloading image %s...' % (comicUrl))
                res = requests.get(comicUrl)
                res.raise_for_status()
                # Save the image to ./xkcd.
                imageFile = open(os.path.join('xkcd', os.path.basename(comicUrl)), 'wb')
                for chunk in res.iter_content(100000):
                imageFile.write(chunk)
                imageFile.close()
    # Create and start the Thread objects.
    downloadThreads = [] # a list of all the Thread objects
    for i in range(0, 1400, 100): # loops 14 times, creates 14 threads
        downloadThread = threading.Thread(target=downloadXkcd, args=(i, i + 99))
        downloadThreads.append(downloadThread)
        downloadThread.start()
    # Wait for all threads to end.
    for downloadThread in downloadThreads:
        downloadThread.join()
        print('Done.')
    
    从 Python 启动其他程序

    利用内建的 subprocess 模块中的 Popen()函数,Python 程序可以启动计算机中的其他程序(Popen()函数名中的 P 表示 process,进程)。如果你打开了一个应用程序的多个实例,每个实例都是同一个程序的不同进程。

    每个进程可以有多个线程。不像线程,进程无法直接读写另一个进程的变量。

    import subprocess
    subprocess.Popen('C:\\Windows\\System32\\calc.exe')
    

    向 Popen()传递命令行参数

    用 Popen()创建进程时,可以向进程传递命令行参数。要做到这一点,向 Popen()传递一个列表,作为唯一的参数。该列表中的第一个字符串是要启动的程序的可执行文件名,所有后续的字符串将是该程序启动时,传递给该程序的命令行参数。

    subprocess.Popen(['C:\\Windows\\notepad.exe', 'C:\\hello.txt'])
    

    运行python脚本

     subprocess.Popen(['C:\\python34\\python.exe', 'hello.py'])
    

    用默认的应用程序打开文件

    import subprocess
    fileObj = open('hello.txt', 'w')
    fileObj.write('Hello world!')
    fileObj.close()
    subprocess.Popen(['start', 'hello.txt'], shell=True)
    

    相关文章

      网友评论

          本文标题:2019实战第二期-时间读书打卡

          本文链接:https://www.haomeiwen.com/subject/odpebqtx.html