python 多线程简单实现

发布时间：2019-07-25 09:19:55编辑：auto阅读（1420）

1. 线程是什么？

线程，有时被称为轻量级进程(Lightweight Process，LWP），是程序执行流的最小单元。

2 为什么要用线程？

a 单个线程可以在进程中独立运行


c 并行操作，适用于C/S架构

3 python怎么生成线程（将函数生成线程）：

# -*- coding: UTF-8 -*-
import threading   #加载线程模块
import time

#演示用函数run
def run(num):  
  print "Hi,I am thread %s.....lalala"  %num
  time.sleep(3)
  
for i in range(30):
  t = threading.Thread(target=run,args=(i,))
  #使用threading模块Thread方法生成一个线程
  #target=你要运行的函数，args=你运行的函数的参数，后面的","是不能省略的
  t.start()
  #调用start方法，执行run()方法，也就是定义的函数

总结：

    生成线程就2个步骤：

     1.加载threading模块

     2.使用threading.Thread方法实例化一个对象就行




4 python怎么生成线程（将类生成线程）：

# -*- coding: UTF-8 -*-
import threading
import time
#将自定义的类，继承threading.Thread方法
class MyThread(threading.Thread):
  #构建初始化类的方法
  def __init__(self,num):
    #继承threading.Thread的初始化类的方法
    threading.Thread.__init__(self)
    self.num = num
  #此处定义的方法名，必须是run方法
  def run(self):
    print "Hi,I am thread %s.....lalala"  %self.num
    time.sleep(3)
  
for i in range(30):
  t = MyThread(i)
  #继承threading.Thread方法后，实例化自定义类后，会自动执行run方法
  t.start()

总结：

    通过自定义类，继承threading.Thread类，要通过一定的规则来生成线程：

    1.自定义类继承threading.Thread类

    2.继承threading.Thread的__init__初始化类的方法

    3.构建run方法

    4.实例化自定义类，就会将自定义类中run方法给自动执行成一个线程




5 线程锁

  如果线程执行的函数内有变量共用一个全局变量，那么并发线程在执行中，会导致这个变量数值出现变化，从而导致结果错误（而线程需要执行的函数内的变量，定义为全局变量本省就不正常）





#!/usr/bin/env python
import threading
import time
number = 0
lock = threading.RLock()
#实例化线程锁Rlock类
def run(num):
  lock.acquire()
  #调用acquire方法为线程加所
  #number = 0
  print "Hi,I am thread %s.....lalala"  %num
  global number
  number +=1
  print "this is thread " ,num,number
  lock.release()
  #调用release方法为线程解锁
  
  time.sleep(3)
  
  
for i in range(30):
  t = threading.Thread(target=run,args=(i,))
  t.start()

补充：

threading.Thread类的使用：

1，在自己的线程类的__init__里调用threading.Thread.__init__(self, name = threadname)

Threadname为线程的名字

2， run()，通常需要重写，编写代码实现做需要的功能。

3，getName()，获得线程对象名称

4，setName()，设置线程对象名称

5，start()，启动线程

6，join([timeout])，等待另一线程结束后再运行。

　    在循环内，join（）的作用是，在子线程完成运行之前，这个子线程的父线程将一直被阻塞。

　　注意:  join()方法的位置是在for循环外的，也就是说必须等待for循环里的两个进程都结束后，才去执行主进程。





7，setDaemon(bool)，设置子线程是否随主线程一起结束，必须在start()之前调用。默认为False。

8，isDaemon()，判断线程是否随主线程一起结束。

9，isAlive()，检查线程是否在运行中。

关键字：