温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

Jython中怎么定义共享缓冲区

发布时间:2021-07-22 14:54:56 来源:亿速云 阅读:117 作者:Leah 栏目:编程语言

这期内容当中小编将会给大家带来有关Jython中怎么定义共享缓冲区,文章内容丰富且以专业的角度为大家分析和叙述,阅读完这篇文章希望大家可以有所收获。

下面是一个使用 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中怎么定义共享缓冲区了,如果刚好有类似的疑惑,不妨参照上述分析进行理解。如果想知道更多相关知识,欢迎关注亿速云行业资讯频道。

向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

AI