multiprocessing

차이

문서의 선택한 두 판 사이의 차이를 보여줍니다.

차이 보기로 링크

--- multiprocessing [2020/06/05 17:44] – rex8312
+++ multiprocessing [2024/03/23 02:38] (현재) – 바깥 편집 127.0.0.1
@@ 줄 1: / 줄 1: @@
 ====== multiprocessing ======
+  * 자식프로세스 출력 redirection
+<code python>
+import app
+import io
+import sys
+from multiprocessing import Process
+def run_app(some_param):
+    sys.stdout = io.TextIOWrapper(open(sys.stdout.fileno(), 'wb', 0), write_through=True)
+    app.run()
+app_process = Process(target=run_app, args=('some_param',))
+app_process.start()
+# Use app_process.termninate() for python <= 3.7.
+app_process.kill()
+# https://stackoverflow.com/questions/7714868/python-multiprocessing-how-can-i-reliably-redirect-stdout-from-a-child-process
+</code>
+<code python>
+original_stdout = sys.stdout
+buffer = deque(maxlen=128)
+class IOLoggerWrapper(io.StringIO):
+    def write(self, string):
+        buffer.append(string)
+        return len(string)
+root = logging.getLogger()
+handler = logging.StreamHandler(IOLoggerWrapper())
+formatter = logging.Formatter("[%(asctime)s][%(name)s][%(levelname)s][%(message)s]")
+handler.setFormatter(formatter)
+root.addHander(handler)
+class IOWrapper(io.StringIO):
+    def write(self, string):
+        original_stdout.write(string)
+        buffer.append(string)
+        return len(string)
+io_wrapper = IOWrapper()
+sys.stdout = io_wrapper
+sys.stderr = io_wrapper
+</code>
+===== multiprocessing 대체 모듈 =====
   * Uber Fiber
@@ 줄 10: / 줄 60: @@
   * Array 공유
     * https://pypi.org/project/SharedArray/

multiprocessing.1591379073.txt.gz · 마지막으로 수정됨: 2024/03/23 02:37 (바깥 편집)