auto commit

wsps/tasks_loop.py

@@ -182,6 +182,32 @@ class globCL(GCLMixin):
 					self.cbs_asap2 = self.cbs_asap
 					self.cbs_asap=[]
 			await asyncio.sleep(self.fast_timeout)
+	async def persistent_fast_cb_loop_(self,*a,**kw):
+		while 1:
+			if len(self.cbs_asap):
+				cbs_once = [*self.cbs_asap]
+				self.cbs_asap=[]
+				k=0
+				for v in cbs_once:
+					try:
+						call_info = callable_helper(v)
+						if (call_info["is_callable"]):
+							if call_info["is_coroutine"]:
+								pass
+								await v({k,self})
+							else:
+								v({k,self})
+						else:
+							pass
+					except Exception as e:
+						p("persistent_fast_cb_loop Exception cbs_once:",e)
+						p(flush=True)
+					else:
+						pass
+					finally:
+						pass
+					k += 1
+			await asyncio.sleep(self.fast_timeout)
 	async def persistent_loop(self,*a,**kw):
 		while 1:
 			for k,v in [*self.cbs.items()]: