File tree Expand file tree Collapse file tree 2 files changed +10
-6
lines changed
Expand file tree Collapse file tree 2 files changed +10
-6
lines changed Original file line number Diff line number Diff line change 11from __future__ import annotations
2- __version__ = "0.1.5 "
2+ __version__ = "0.1.6 "
33__doc__ = """
44Logging utility v{}
55Copyright (C) 2021 Fusion Solutions KFT <contact@fusionsolutions.io>
Original file line number Diff line number Diff line change 11# Builtin modules
22from __future__ import annotations
33import re , os , traceback
4+ from threading import Lock
45from glob import glob
56from datetime import datetime , timezone
67from typing import List , Tuple , Any , Optional
@@ -72,9 +73,11 @@ def close(self) -> None:
7273class FileStream (T_ModuleBase ):
7374 fullPath :str
7475 stream :Any
76+ lock :Lock
7577 def __init__ (self , fullPath :str ):
7678 self .fullPath = fullPath
7779 self .stream = None
80+ self .lock = Lock ()
7881 self .open ()
7982 def open (self ) -> None :
8083 try :
@@ -87,11 +90,12 @@ def open(self) -> None:
8790 traceback .print_exc ()
8891 def write (self , data :str ) -> None :
8992 if self .stream is not None :
90- try :
91- self .stream .write (data )
92- self .stream .flush ()
93- except :
94- traceback .print_exc ()
93+ with self .lock :
94+ try :
95+ self .stream .write (data )
96+ self .stream .flush ()
97+ except :
98+ traceback .print_exc ()
9599 def emit (self , message :str ) -> None :
96100 self .write (message )
97101 def close (self ) -> None :
You can’t perform that action at this time.
0 commit comments