Jython中怎么定义共享缓冲区
这期内容当中小编将会给大家带来有关Jython中怎么定义共享缓冲区，文章内容丰富且以专业的角度为大家分析和叙述，阅读完这篇文章希望大家可以有所收获。
创新互联公司提供网站设计制作、成都网站制作、网页设计，品牌网站制作，1元广告等致力于企业网站建设与公司网站制作，10多年的网站开发和建站经验,助力企业信息化建设，成功案例突破1000多家,是您实现网站建设的好选择.
下面是一个使用 Jython线程的例子。这个例子显示了一组生产者（producer）和消费者（consumer）线程，它们共享对一个公共缓冲区的访问。我们首先定义这个共享缓冲区，如下所示：
""" Jython线程示例 """ from java import lang from synchronize import * from thread import start_new_thread from sys import stdout def __waitForSignal (monitor): apply_synchronized(monitor, lang.Object.wait, (monitor,)) def __signal (monitor): apply_synchronized(monitor, lang.Object.notifyAll, (monitor,)) def __xprint (stream, msg): print >>stream, msg def xprint (msg, stream=stdout): """ Synchronized print. """ apply_synchronized(stream, __xprint, (stream, msg)) class Buffer: """ A thread-safe buffer. """ def __init__ (self, limit=-1): self.__limit = limit # the max size of the buffer self.__data = [] self.__added = () # used to signal data added self.__removed = () # used to signal data removed def __str__ (self): return "Buffer(%s,%i)" % (self.__data, self.__limit) def __len__ (self): return len(self.__data) def add (self, item): """ 添加项目。满的时候等待。 """ if self.__limit >= 0: while len(self.__data) > self.__limit: __waitForSignal(self.__removed) self.__data.append(item); xprint("Added: %s" % item) __signal(self.__added) def __get (self): item = self.__data.pop(0) __signal(self.__removed) return item def get (self, wait=1): """ Remove an item. Wait if empty. """ item = None if wait: while len(self.__data) == 0: __waitForSignal(self.__added) item = self.__get() else: if len(self.__data) > 0: item = self.__get() xprint("Removed: %s" % item) return item get = make_synchronized(get)上述就是小编为大家分享的Jython中怎么定义共享缓冲区了，如果刚好有类似的疑惑，不妨参照上述分析进行理解。如果想知道更多相关知识，欢迎关注创新互联行业资讯频道。
网页题目：Jython中怎么定义共享缓冲区
链接地址：http://scjbc.cn/article/pgjghj.html
