home *** CD-ROM | disk | FTP | other *** search
/ Mac Easy 2010 May / Mac Life Ubuntu.iso / casper / filesystem.squashfs / usr / lib / rhythmbox / plugins / rb / Coroutine.py < prev    next >
Encoding:
Python Source  |  2009-04-07  |  2.2 KB  |  66 lines
  1. # -*- Mode: python; coding: utf-8; tab-width: 8; indent-tabs-mode: t; -*- 
  2. #
  3. # Copyright (C) 2006 - Ed Catmur <ed@catmur.co.uk>
  4. #
  5. # This program is free software; you can redistribute it and/or modify
  6. # it under the terms of the GNU General Public License as published by
  7. # the Free Software Foundation; either version 2, or (at your option)
  8. # any later version.
  9. #
  10. # The Rhythmbox authors hereby grant permission for non-GPL compatible
  11. # GStreamer plugins to be used and distributed together with GStreamer
  12. # and Rhythmbox. This permission is above and beyond the permissions granted
  13. # by the GPL license by which Rhythmbox is covered. If you modify this code
  14. # you may extend this exception to your version of the code, but you are not
  15. # obligated to do so. If you do not wish to do so, delete this exception
  16. # statement from your version.
  17. # 
  18. # This program is distributed in the hope that it will be useful,
  19. # but WITHOUT ANY WARRANTY; without even the implied warranty of
  20. # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  21. # GNU General Public License for more details.
  22. #
  23. # You should have received a copy of the GNU General Public License
  24. # along with this program; if not, write to the Free Software
  25. # Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301  USA.
  26.  
  27. class Coroutine:
  28.     """A simple message-passing coroutine implementation. 
  29.     Not thread- or signal-safe. 
  30.     Usage:
  31.         def my_iter (plexer, args):
  32.             some_async_task (..., callback=plexer.send (tokens))
  33.             yield None
  34.             tokens, (data, ) = plexer.receive ()
  35.             ...
  36.         Coroutine (my_iter, args).begin ()
  37.     """
  38.     def __init__ (self, iter, *args):
  39.         self._continuation = iter (self, *args)
  40.         self._executing = False
  41.     def _resume (self):
  42.         if not self._executing:
  43.             self._executing = True
  44.             try:
  45.                 try:
  46.                     self._continuation.next ()
  47.                     while self._data:
  48.                         self._continuation.next ()
  49.                 except StopIteration:
  50.                     pass
  51.             finally:
  52.                 self._executing = False
  53.     def clear (self):
  54.         self._data = []
  55.     def begin (self):
  56.         self.clear ()
  57.         self._resume ()
  58.     def send (self, *tokens):
  59.         def callback (*args):
  60.             self._data.append ((tokens, args))
  61.             self._resume ()
  62.         return callback
  63.     def receive (self):
  64.         return self._data.pop (0)
  65.  
  66.