python使用多线程创建一个Buffer缓存器的实现思路_python线程池处理数据

python

194 浏览量更新于2023-03-03 评论收藏 65KB PDF 举报

身份认证购VIP最低享 7 折!

领优惠券(最高得80元）

资源详情

资源评论

资源推荐

python 使用多线程创建一个使用多线程创建一个Buffer缓存器的实现思路缓存器的实现思路

这几天学习人脸识别的时候，虽然运行的没有问题，但我却意识到了一个问题

在图片进行传输的时候，GPU的利用率为0

也就是说，图片的传输速度和GPU的处理速度不能很好衔接

于是，我打算利用多线程开发一个buffer缓存

实现的思路如下实现的思路如下

定义一个Buffer类，再其构造函数中创建一个buffer空间（这里最好使用list类型）

我们还需要的定义线程锁LOCK（数据传输和提取的时候会用到）

因为需要两种方法（读数据和取数据），所以我们需要定义两个锁

实现的代码如下：

#-*-coding:utf-8-*-

import threading

class Buffer:

def __init__(self,size):

self.size = size

self.buffer = [] self.lock = threading.Lock()

self.has_data = threading.Condition(self.lock) # small sock depand on big sock

self.has_pos = threading.Condition(self.lock)

def get_size(self):

return self.size

def get(self):

with self.has_data:

while len(self.buffer) == 0:

print("I can't go out has_data")

self.has_data.wait()

print("I can go out has_data")

result = self.buffer[0] del self.buffer[0] self.has_pos.notify_all()

return result

def put(self, data):

with self.has_pos:

#print(self.count)

while len(self.buffer)>=self.size:

print("I can't go out has_pos")

self.has_pos.wait()

print("I can go out has_pos")

# If the length of data bigger than buffer's will wait

self.buffer.append(data)

# some thread is wait data ,so data need release

self.has_data.notify_all()

if __name__ == "__main__":

buffer = Buffer(3)

def get():

for _ in range(10000):

print(buffer.get())

def put():

a = [[1,2,3,4,5,6,7,8,9],[1,2,3,4,5,6,7,8,9],[1,2,3,4,5,6,7,8,9]] for _ in range(10000):

buffer.put(a)

th1 = threading.Thread(target=put)

th2 = threading.Thread(target=get)

th1.start()

th2.start()

th1.join()

th2.join()

总结总结

您可能感兴趣的文章您可能感兴趣的文章:Python QTimer实现多线程及QSS应用过程解析详解Python多线程下的listPython3 socket即时通讯脚本实现代码实例(threading多线程)python多线程实现同时执行两个while循环的操

作浅谈Python3多线程之间的执行顺序问题Python多线程:主线程等待所有子线程结束代码Python3如何使用多线程升程序运行速度

本内容试读结束，登录后可阅读更多

下载后可阅读完整内容，剩余0页未读，立即下载

weixin_38552083

粉丝: 7
资源: 888

会员权益专享

python 使用多线程创建一个Buffer缓存器的实现思路

评论0

会员权益专享

最新资源

python 使用多线程创建一个Buffer缓存器的实现思路

评论0

python 多线程实现多个网址的多次快速访问

python多线程同步之文件读写控制

深入理解Python 多线程

创建一段buffer 队列缓存

python 创建多线程

python的多线程与C#多线程的区别

python的多线程和pyqt的多线程有什么区别

python使用多线程

Python实现多线程

python实现多线程的方式

python 多线程 多线程

python的多线程和Java的多线程有什么联系和区别吗

python实现多线程和多进程

python threading 多线程

python turtle 多线程

python多线程并发

为什么python的多线程被称为伪多线程

python多线程创建

python 多线程 多进程 装饰器

python cuda 多线程

会员权益专享

最新资源

python 多线程多线程

python 多线程多进程装饰器