python多线程（一）

时间：2023-03-10 07:27:37
python多线程（一）

---恢复内容开始---

首先先来看个单线程的例子：

from time import ctime,sleep

def music():

    for i in range():

        print("I was listening to music. %s" %ctime())

        sleep()

def move():

    for i in range():

        print("I was at the movies! %s" %ctime())

        sleep()

if __name__ == '__main__':

    music()

    move()

    print("all over %s" %ctime())

首先先听了一首music，觉得音乐好听，就用for循环来控制音乐的播放了两次，每首音乐播放需要1秒钟，sleep()来控制音乐播放的时长,

听说有部电影好看，我们就去看，每一场电影需要5秒钟，电影是在太好看了，我们有for循环2次运行结果如下：

我正在听音乐. Sun May  ::

我正在听音乐. Sun May  ::

你正在看抖音! Sun May  ::

你正在看抖音! Sun May  ::

all over Sun May  ::

[Finished in .2s]

通过上边我们看到有两个方法，想到我们可不可以自定义听什么歌，看抖音什么类型的短视频

于是对上面代码加以改造：

from time import ctime,sleep

def music(song):
for i in range(2):
print("我正在听%s音乐. %s" %(song,ctime()))
sleep(1)

def move(tv):
for i in range(2):
print("你正在看抖音%s短视频! %s" %(tv,ctime()))
sleep(5)

if __name__ == '__main__':
music('纸短情长')
move('吃鸡')
print("all over %s" %ctime())

看到了吧 我们加了个参数，运行结果：

我正在听纸短情长音乐. Sun May  ::

我正在听纸短情长音乐. Sun May  ::

你正在看抖音吃鸡短视频! Sun May  ::

你正在看抖音吃鸡短视频! Sun May  ::

all over Sun May  ::

[Finished in .2s]

多线程：体现了一下单线程的使用，那么我们就来看看多线程到底有什么更加强大的功能

from time import ctime, sleep

import threading

def music(song):

    for i in range():

        print("I was listening to %s. %s" % (song, ctime()))

        sleep()

def move(mymove):

    for i in range():

        print("I was at the %s! %s" % (mymove, ctime()))

        sleep()

threads = []

th1 = threading.Thread(target=music, args=('一个人走',))

threads.append(th1)

th2 = threading.Thread(target=move, args=('复仇者联盟',))

threads.append(th2)

if __name__ == '__main__':

    for t in threads:

        t.setDaemon(True)  # setDaemon(True)将线程声明为

        # 守护线程，必须在start() 方法调用之前设置，如果

        # 不设置为守护线程程序会被无限挂起。子线程启动后，

        # 父线程也继续执行下去，当父线程执行完最后一条语句

        t.start()

    t.join()#程序加了个join()方法，用于等待线程

    # 终止。join（）的作用是，在子线程完成运行之前，这个子线

    # 程的父线程将一直被阻塞。

    print("all over %s" % ctime())

首先肯定是要导入threading模块：import threading

threads = []

th1 = threading.Thread(target=music, args=('一个人走',))

threads.append(th1)

　　创建了threads数组，创建线程th1,使用threading.Thread()方法，在这个方法中调用music方法target=music，args方法对music进行传参。 把创建好的线程t1装到threads数组中。

　　接着以同样的方式创建线程th2，并把t2也装到threads数组。

for t in threads:

　　t.setDaemon(True)

　　t.start()

最后通过for循环遍历数组。（数组被装载了t1和t2两个线程）

setDaemon()

　　setDaemon(True)将线程声明为守护线程，必须在start() 方法调用之前设置，如果不设置为守护线程程序会被无限挂起。子线程启动后，父线程也继续执行下去，当父线程执行完最后一条语句print "all over %s" %ctime()后，没有等待子线程，直接就退出了，同时子线程也一同结束。

start()

开始线程活动。

运行结果:

I was listening to 一个人走. Sun May  ::

I was at the 复仇者联盟! Sun May  ::

I was listening to 一个人走. Sun May  ::

I was at the 复仇者联盟! Sun May  ::

all over Sun May  ::

[Finished in .3s]

到这里，我们发现如果我有好多个线程，那岂不是我每个线程都要创建一个th~

#!user/bin/env python

# coding=utf-

from time import ctime, sleep

import threading

def music(song):

    for i in range():

        print("I was listening to %s. %s" % (song, ctime()))

        sleep()

def move(mymove):

    for i in range():

        print("I was at the %s! %s" % (mymove, ctime()))

        sleep()

def new_threading(name):

    new_thread = name.split('.')[]

    if new_thread == 'mp3':

        music(name)

    else:

        if new_thread == 'mp4':

            move(name)

        else:

            print('error:The format is not recognized!')

list = ['纸短情长.mp3', '复仇者联盟.mp4']

threads = []

file_count = range(len(list))

# 创建线程

for i in file_count:

    t = threading.Thread(target=new_threading, args=(list[i],))

    threads.append(t)

    # 启动线程

if __name__ == '__main__':

    for t in file_count:

        threads[t].start()

    for t in file_count:

        threads[t].join()

    print("all over %s" % ctime())

我们增加了一个增加线程的方法，只要想 list中添加一个文件，程序会自动为其创建线程

I was listening to 纸短情长.mp3. Sun May  ::

I was at the 复仇者联盟.mp4! Sun May  ::

I was listening to 纸短情长.mp3. Sun May  ::

I was at the 复仇者联盟.mp4! Sun May  ::

all over Sun May  ::

[Finished in .2s]

是不是实现了 ，我们继续优化，发现new——threading中有个判断文件扩展名的，然后才调用music和move(）

那为什么不用一个方法（也就是一个软件）同时播放音乐和电影呢

#!user/bin/env python

# coding=utf-

from time import ctime, sleep

import threading

def super_player(file_type,time):

    for i in range():

        print("正在播放 %s. %s" % (file_type, ctime()))

        sleep(time)

list ={'纸短情长.mp3':, '复仇者联盟3.mp4':,'人民的名义.wav':}

threads = []

file_count = range(len(list))

# 创建线程

for file_type,time in list.items():

    t = threading.Thread(target=super_player, args=(file_type,time))

    threads.append(t)

    # 启动线程

if __name__ == '__main__':

    for t in file_count:

        # [t].setDaemon(True)  # setDaemon(True)将线程声明为

        # 守护线程，必须在start() 方法调用之前设置，如果

        # 不设置为守护线程程序会被无限挂起。子线程启动后，

        # 父线程也继续执行下去，当父线程执行完最后一条语句

        threads[t].start()

    for t in file_count:

        threads[t].join()

    # t.join()#只对上面的程序加了个join()方法，用于等待线程

    # 终止。join（）的作用是，在子线程完成运行之前，这个子线

    # 程的父线程将一直被阻塞。

    print("all over %s" % ctime())

这里我们将list换成字典，定义播放的文件和时长，通过字典的items()方法来循环的取file和time，取到的这两个值用于创建线程。

创建super_player()函数，用于接收file和time，用于确定要播放的文件及时长。运行结果如下：

正在播放 纸短情长.mp3. Sun May  ::

正在播放 复仇者联盟3.mp4. Sun May  ::

正在播放 人民的名义.wav. Sun May  ::

正在播放 纸短情长.mp3. Sun May  ::

正在播放 复仇者联盟3.mp4. Sun May  ::

正在播放 人民的名义.wav. Sun May  ::

all over Sun May  ::

[Finished in .2s]

相关文章