From fe63c74425b7ed601531099adce0a8c53ac9cb04 Mon Sep 17 00:00:00 2001
From: anni57779821988 <134767082+anni57779821988@users.noreply.github.com>
Date: Sat, 27 May 2023 14:32:21 +0200
Subject: [PATCH] Create help

---
 help | 39 +++++++++++++++++++++++++++++++++++++++
 1 file changed, 39 insertions(+)
 create mode 100644 help

diff --git a/help b/help
new file mode 100644
index 0000000..0084963
--- /dev/null
+++ b/help
@@ -0,0 +1,39 @@
+import time
+
+class Timing(object):
+  def __init__(self, prefix="", on_exit=None, enabled=True): self.prefix, self.on_exit, self.enabled = prefix, on_exit, enabled
+  def __enter__(self): self.st = time.perf_counter_ns()
+  def __exit__(self, exc_type, exc_val, exc_tb):
+    self.et = time.perf_counter_ns() - self.st
+    if self.enabled: print(f"{self.prefix}{self.et*1e-6:.2f} ms"+(self.on_exit(self.et) if self.on_exit else ""))
+
+def enable_early_exec():
+  import subprocess, multiprocessing
+  qin: multiprocessing.Queue = multiprocessing.Queue()
+  qout: multiprocessing.Queue = multiprocessing.Queue()
+  def _early_exec_process(qin, qout):
+    while 1:
+      path, inp = qin.get()
+      qout.put(subprocess.check_output(path, input=inp))
+  p = multiprocessing.Process(target=_early_exec_process, args=(qin, qout))
+  p.daemon = True
+  p.start()
+  def early_exec(x):
+    qin.put(x)
+    return qout.get()
+  return early_exec
+
+def proc(itermaker, q):
+  for x in itermaker(): q.put(x)
+  q.close()
+
+def cross_process(itermaker, maxsize=8):
+  # TODO: use cloudpickle for itermaker
+  import multiprocessing
+  q: multiprocessing.Queue = multiprocessing.Queue(maxsize)
+  p = multiprocessing.Process(target=proc, args=(itermaker, q))
+  p.daemon = True
+  p.start()
+
+  # TODO: write tests and handle exit case
+  while 1: yield q.get()