Thrading线程

单线程执行代码：

import time


def saySorry():
    print("测试代码")
    time.sleep(1)


if __name__ == '__main__':
    for i in range(5):
        saySorry()

单线程下程序运行非常慢，且不能同一时间执行不同的功能。使用多线程后执行代码较快，且能同一时间完成多种功能（例如：同时接收和发送数据）

import threading
import time


def test():
    print("测试代码")
    time.sleep(1)


if __name__ == '__main__':
    for i in range(5):
        t = threading.Thread(target=test)
        t.start()   # 调用start方法后才会创建线程以及让这个线程开始运行

查看线程数量：通过查看threading调用enumerate方法的长度 来判断线程的数量

print("当前运行的线程数为：%d" %len(threading.enumerate())

线程执行代码的封装：

　　如果使用多个线程去做同一件事情时，可以将线程执行代码进行封装，当需要执行相应代码时直接用封装的代码创建线程对象，然后调用start方法后即可执行。

import threading
import time


class MyThred(threading.Thread):
    def run(self):
        for i in range(5):
            time.sleep(1)
            print("测试代码")


if __name__ == '__main__':
    t = MyThred()
    t.start()

多线程共享全局变量：

from threading import Thread
import time

g_num = 100


def work1():
    global g_num
    for i in range(3):
        g_num += 1
    print("___in worrk1,g_num is %d" % g_num)


def work2():
    # global g_num
    print("___in work2,g_num is %d" % g_num)


print("___线程创建之前，g_num is %d" % g_num)


t1 = Thread(target=work1)
t1.start()

# 延迟一会，保证t1线程中的事情做完
time.sleep(0.5)

t2 = Thread(target=work2)
t2.start()

　　执行结果：

___线程创建之前，g_num is 100
___in worrk1,g_num is 103
___in work2,g_num is 103

补充：threading.Thread()括号内除了传入target=方法名外，还可以用 args=()传入实参到要执行的方法内部，args必须是元组。

from threading import Thread
import time


def work1(temp):
    temp.append(33)
    print("___in work1___", temp)


def work2(temp):
    print("___in work2___", temp)


g_nums = [11, 22]

# target指定将来这个线程去哪个函数执行代码
# args指定将来调用函数的时候 传递什么数据过去
t1 = Thread(target=work1, args=(g_nums,))    # args传入的是一个元组
t1.start()
time.sleep(1)
t2 = Thread(target=work2, args=(g_nums,))
t2.start()

　　执行结果：

___in work1___ [11, 22, 33]
___in work2___ [11, 22, 33]