@@ -70,35 +70,35 @@ public class Tracer implements Runnable {
7070 .booleanValue ();
7171
7272 static class AsyncLogger extends Thread {
73- final PrintStream ps ;
74- final LinkedBlockingQueue <Object > queue = new LinkedBlockingQueue <Object >();
75- public AsyncLogger (PrintStream ps ){
76- this .ps = ps ;
77- start ();
78- }
79-
80- void printMessage (Object message ){
81- if (message instanceof Throwable ){
82- ((Throwable )message ).printStackTrace (ps );
83- } else if (message instanceof String ){
84- ps .println (message );
85- } else {
86- throw new RuntimeException ("Unrecognised object " + message );
73+ final PrintStream ps ;
74+ final LinkedBlockingQueue <Object > queue = new LinkedBlockingQueue <Object >();
75+ public AsyncLogger (PrintStream ps ){
76+ this .ps = ps ;
77+ start ();
8778 }
88- }
8979
90- @ Override public void run (){
91- try {
92- while (true ){
93- printMessage (queue .take ());
94- }
95- } catch (InterruptedException interrupt ){
80+ void printMessage (Object message ){
81+ if (message instanceof Throwable ){
82+ ((Throwable )message ).printStackTrace (ps );
83+ } else if (message instanceof String ){
84+ ps .println (message );
85+ } else {
86+ throw new RuntimeException ("Unrecognised object " + message );
87+ }
88+ }
89+
90+ @ Override public void run (){
91+ try {
92+ while (true ){
93+ printMessage (queue .take ());
94+ }
95+ } catch (InterruptedException interrupt ){
96+ }
9697 }
97- }
9898
99- public void log (Object message ){
100- queue .add (message );
101- }
99+ public void log (Object message ){
100+ queue .add (message );
101+ }
102102 }
103103
104104 public static void main (String [] args ) {
0 commit comments