auto commit

wsps/tasks_loop.py

 		self.rconn = connect_redis()
 		self.rman = RldMan()
 		self.cbs_once = []
+		self.cbs_asap2 = []
 		self.cbs_asap = []
 		self.cbs_once_set = set()
 		self.cbs = {"fn1":fn1,"fn2x":nop}
 		self.fast_timeout = .1
 		pass
 	async def persistent_fast_cb_loop(self,*a,**kw):
+
 		while 1:
-			if len(self.cbs_asap):
-				cbs_once = [*self.cbs_asap]
-				self.cbs_asap=[]
+
+			if len(self.cbs_asap2):
+				cbs_once = [*self.cbs_asap2]
+				# self.cbs_asap2=[]
 				k=0
 				for v in cbs_once:
 					try:
 					finally:
 						pass
 					k += 1
+				if len(self.cbs_asap):
+					self.cbs_asap2 = self.cbs_asap
+					self.cbs_asap=[]
 			await asyncio.sleep(self.fast_timeout)
 	async def persistent_loop(self,*a,**kw):
 		while 1: