PythonでBounded Buffer

引き続きPythonでマルチスレッドプログラミングという事で、5月頃にOS演習で実装したBounded Bufferを実装しました。

Bounded Bufferとは生産者スレッドと消費者スレッドがあり、お互いが有限のバッファでデータをやりとりする際に用いられるものです。「生産者消費者問題」とかでググると出てくると思います。
コードは以下のようになりました。
[code]
import os
import sys
from threading import *
class BoundedBuffer:
def __init__(self, maxlen):
self.cv = Condition()
self.datalist = []
self.maxlen = maxlen
return
def produce(self, item):
self.cv.acquire()
while len(self.datalist) == self.maxlen:
self.cv.wait()
self.datalist.append(item)
self.cv.notifyAll()
self.cv.release()
return
def consume(self):
self.cv.acquire()
while (len(self.datalist) == 0)
self.cv.wait()
ret = self.datalist.pop(0)
self.cv.notifyAll()
self.cv.release()
return ret
[/code]
条件変数がさっくりと書けてしまいます。今回は中の条件もいじりたかったので自分で書いたのですが、普通はQueueクラスを使えば十分間に合いそうです。

Similar Posts:

• PythonでMultiThreadServer
• Async IO on lighttpd
• GDB: Debugging programs with multiple threads