开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 游戏 > 其他游戏 > 查看源码
deferred.py
资源名称：MMOPRG_server_dev.rar　[点击查看]
上传用户：ghyvgy
上传日期：2009-05-26
资源大小：547k
文件大小：3k
源码类别：

其他游戏

开发平台：

Python

deferred.py：源码内容
  1. # deferred.py
  2. #
  3. # Implement a deferred (asynchronous) call framework.
  4. # Allows the storing of method and function calls in
  5. # a list, sorted by the time in which they are to be 
  6. # called. Using this module, a client may schedule a
  7. # call on any object that is addressable via the objmgr
  8. # module (i.e. has an id).
  9. #
  10. # Author: Matthew Walker
  11. #         mwalker@softhome.net
  12. #
  14. import time
  15. import bisect  # efficient list operations
  16. import objmgr
  18. # module-scoped list; protect against reload
  19. try:
  20.   deferredCalls
  21. except NameError:
  22.   deferredCalls = []
  25. class DeferredCall:
  26.   """
  27.   Responsible for representing the state of a method or
  28.   function call that is intended to be executed at some
  29.   time in the future.
  30.   """
  31.   def __init__(self, id, call, args, t, cb, cbArgs):
  32.     self.targetId  = id
  33.     self.call      = call
  34.     self.args      = args
  35.     self.time      = t
  36.     self.callback  = cb
  37.     self.cbArgs    = cbArgs
  39.   def __cmp__(self, other):
  40.     return cmp(self.time, other.time)
  42.   def __call__(self):
  43.     """
  44.     Make this class a callable object (a.k.a. a functor),
  45.     which acts just like a fuction or method.
  46.     """
  47.     target = objmgr.GetObject(self.targetId)
  48.     if target is not None:
  49.       try:
  50.         method = getattr(target, self.call)
  51.       except AttributeError:
  52.         print "No %s on %s" % (self.call, target)
  53.         return
  55.       apply(method, self.args) # make the call
  57.       if self.callback is not None:
  58.         # notify that call is complete
  59.         apply(self.callback, self.cbArgs)
  60.     else:
  61.       print 'No valid target for %s' % (self,)
  63.   def __repr__(self):
  64.     """
  65.     Return a string representation of this object.
  66.     """
  67.     return '<%s: call [%s] args [%s] time [%s] cb [%s] cbArgs [%s]>' % 
  68.       (self.__class__.__name__, self.call, self.args, self.time, self.callback, self.cbArgs)
  71. def Call(target, call, args, delay=0, cb=None, cbArgs=()):
  72.   """
  73.   Schedule a call for later execution. This 
  74.   is the API for making a deferred call.
  75.   """
  76.   #print 'Call( %s, %s, %s, %s, %s, %s )' % (target, call, args, delay, cb, cbArgs)
  77.   callTime = time.time() + float(delay) / 1000.0
  78.   dCall = DeferredCall(target, call, args,
  79.                        callTime, cb, cbArgs)
  80.   bisect.insort_right(deferredCalls, dCall)
  83. def ExecuteDeferredCalls():
  84.   """
  85.   Run deferred method calls whose time has come.
  86.   """
  87.   dCall = None
  88.   now = time.time()
  89.   while deferredCalls:
  90.     dCall = deferredCalls.pop(0) # front of the list
  91.     if dCall.time > now:
  92.       # not time yet, put it back at front of the list
  93.       deferredCalls.insert(0, dCall)
  94.       break
  95.     
  96.     dCall() # execute the call, and any callbacks
  98.   # now return how long in ms until next call
  99.   next = None  # forever
  100.   if dCall is not None:
  101.     next = int((dCall.time - time.time()) * 1000.0)
  102.     if next < 0:
  103.       next = 0
  105.   return next