Jython中怎么定義共享緩沖區(qū)

這期內(nèi)容當中小編將會給大家?guī)碛嘘PJython中怎么定義共享緩沖區(qū)，文章內(nèi)容豐富且以專業(yè)的角度為大家分析和敘述，閱讀完這篇文章希望大家可以有所收獲。

下面是一個使用 Jython線程的例子。這個例子顯示了一組生產(chǎn)者（producer）和消費者（consumer）線程，它們共享對一個公共緩沖區(qū)的訪問。我們首先定義這個共享緩沖區(qū)，如下所示：

""" 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中怎么定義共享緩沖區(qū)了，如果剛好有類似的疑惑，不妨參照上述分析進行理解。如果想知道更多相關知識，歡迎關注億速云行業(yè)資訊頻道。