moratorium

Bounded Bufferとは生産者スレッドと消費者スレッドがあり、お互いが有限のバッファでデータをやりとりする際に用いられるものです。「生産者消費者問題」とかでググると出てくると思います。

コードは以下のようになりました。

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

条件変数がさっくりと書けてしまいます。今回は中の条件もいじりたかったので自分で書いたのですが、普通はQueueクラスを使えば十分間に合いそうです。