auto commit

wsps/tasks_loop.py

@@ -172,10 +172,43 @@ class globCL(GCLMixin):
 		self.rconn = connect_redis()
 		self.rman = RldMan()
 		self.cbs_once = []
+		self.cbs_asap = []
 		self.cbs_once_set = set()
 		self.cbs = {"fn1":fn1,"fn2x":nop}
 		self.timeout = 1
+		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=[]
+				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
+						# p(k,v)
+
+						pass
+					except Exception as e:
+						p("persistent_fast_cb_loop Exception cbs_once:",e)
+						p(flush=True)
+						# raise
+					else:
+						pass
+					finally:
+						pass
+					k += 1
+			await asyncio.sleep(self.timeout)
 	async def persistent_loop(self,*a,**kw):
 		while 1:
 			# p("PL:",time.time(),flush=1)
@@ -244,6 +277,7 @@ class globCL(GCLMixin):
 		self.run_persistent_loop = nop
 		self.rman.persistent_loop_cb()
 		loop.create_task(self.persistent_loop())
+		loop.create_task(self.persistent_fast_cb_loop())
 		self.loop = loop
 	run_persistent_loop = _run_persistent_loop