threading包

Posted 小丑_jk

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了threading包相关的知识,希望对你有一定的参考价值。

参考:https://www.cnblogs.com/tkqasn/p/5700281.html

参考:https://www.cnblogs.com/tkqasn/p/5700281.html

threading用于提供线程相关的操作,线程是程序工作中最小的单元,python当前版本的多线程库中没有实现优先级、线程组、线程也不能被停止、暂停、恢复、中断。

threading中提供的类包括Thread、Lock、RLock、Condition、Event、Timer等

threading模块提供的常用方法包括:

threading.currentThread():返回当前的线程变量

threading.enumerate():返回一个包含当前正在运行的线程的list

threading.activeCount():返回正在运行的线程数量,与len(threading.enumerate())的效果相同

threading模块提供的常量:

threading.TIMEOUT_MAX:设置threading全局超时时间

简易的开启线程:

def sayhi(k):
    print(\'your id is %s\' %k)  
t=threading.Thread(target=sayhi,args=(\'hh\',))     #第一个参数target是线程函数变量,第二个参数args是一个数组变量参数如果只传递一个值就只需要一个i,如果要传递多个参数,那么还可以继续传递其他参数,其中逗号不能少,少了则不是数组。
t.start()
#type((1,))的返回结果为数组tuple

创建线程的两种方法:

import threading
import time
#方法一:将要执行的方法作为参数传给Thread的构造方法
def action(arg):
    time.sleep(1)
    print (\'the arg is:%s\\r\' %arg)   #\\r表示指针回到该行开头
for i in range(4):
    t =threading.Thread(target=action,args=(i,))   #开启线程,target表示要执行的方法,name表示线程名,args/kwargs表示要传入方法的参数
    t.start()
print (\'main thread end!\')
# 或者先建Thread的一个继承类,然后用这个类中的start()方法打开:
t=threading.Thread(target=action,args=(\'hh\',))
t.start()
#方法二:从Thread继承,并重写run()
class MyThread(threading.Thread):
    def __init__(self,arg):
        super(MyThread, self).__init__()#注意:一定要显式的调用父类的初始化函数。
        self.arg=arg
    def run(self):#定义每个线程要运行的函数
        time.sleep(1)
        print (\'the arg is:%s\\r\' % self.arg)

for i in range(4):
    t =MyThread(i)
    t.start()

print (\'main thread end!\')

 简单的线程实例:

import threading  
import queue  
import time  
class mn_access(threading.Thread):  
 def __init__(self,interval):  
  threading.Thread.__init__(self)  
  self.interval=interval  
  self.thread_stop=False  
 def run(self):      #这个函数中存放用户自己的功能代码  
  i=1;  
  while not self.thread_stop:  
   print("thread%d %s: i am alive hehe %d" %(self.ident,self.name,i))     #name用于存放线程的名字,ident用于存放线程的标识
   time.sleep(self.interval)  
   i=i+1  
 def stop(self):  
  self.thread_stop = True  
if __name__ == "__main__":  
 mn=mn_access(1)  
 mn.start()     #线程开始  
 time.sleep(5)  
 mn.stop()

 queue包的例子:

class workder(threading.Thread):
    def __init__(self,queue):
        threading.Thread.__init__(self)
        self.queue=queue
        self.thread_stop=False
    def run(self):
        while not self.thread_stop:
            print(\'thread %d %s :waiting for tast\' %(self.ident,self.name))
            try:
                task=q.get(block=True,timeout=20)           #接收消息
            except queue.Empty:
                print(\'nothing to do! i will go home\')
                self.thread_stop=True
                break
            print(\'task recv:%s,task no %d \' %(task[0],task[1]))
            print(\'i am working\')
            time.sleep(3)
            print(\'work finished\')
            q.task_done()             #完成一个任务
            res=q.qsize()             #判断队列的大小
            if res>0:
                print(\'fuck there are still %d task to do \'%res)
    def stop(self):
        self.thread_stop=True
if __name__==\'__main__\':
    q=queue.Queue(3)
    worker=workder(q)
    worker.start()
    q.put([\'produce one cup\',1],block=True,timeout=None)           #产生任务消息
    q.put([\'produce one desk\',2],block=True,timeout=None)
    q.put([\'produce one apple\',3],block=True,timeout=None)
    q.put([\'produce one banana\',4],block=True,timeout=None)
    q.put([\'produce one bag\',5],block=True,timeout=None)
    print(\'********wait for finish\')
    q.join()           #等待所有任务完成
    print(\'all task finished\')

 

以上是关于threading包的主要内容,如果未能解决你的问题,请参考以下文章

面向面试编程代码片段之GC

python threading超线程使用简单范例的代码

线程操作API

具有运行时 pojos 的带有 Hibernate 的 OSGi 片段包

java线程

vscode用啥符号把某一段代码包起来,类似C#的#region?