update benchmark

adapter/fake/adapter.go

@@ -22,7 +22,7 @@ func (w *Writer) Write(b []byte) (int, error) {
 	if w.withErr != nil {
 		return 0, w.withErr
 	}
-	time.Sleep(time.Nanosecond * 20)
+	time.Sleep(time.Nanosecond * 200)
 	w.b = append(w.b, b...)
 	return len(b), nil
 }

adapter/fakeSync/adapter.go

@@ -43,7 +43,7 @@ func (w *ReadWriter) Read() []byte {
 // NewAdapter create a fake adapter with sync read method
 func NewAdapter(l ...level.LogLevel) *ReadWriter {
 	w := &ReadWriter{
-		done: make(chan struct{}, 100),
+		done: make(chan struct{}, 1),
 	}
 	if len(l) > 0 {
 		w.logLevel = l[0]

gol_test.go

@@ -476,7 +476,9 @@ func BenchmarkLog(b *testing.B) {
 	b.ResetTimer()
 
 	for i := 0; i < b.N; i++ {
-		l.Println("Hello")
+		for j := 0; j < 100; j++ {
+			l.Println("Hello")
+		}
 	}
 }
 
@@ -486,30 +488,9 @@ func BenchmarkGol(b *testing.B) {
 	// g.SetOption(0)
 	g.AddLogAdapter("fake", fake.NewAdapter(level.DEBUG))
 	b.ResetTimer()
-	for i := 0; i < b.N; i++ {
-		g.Debug("Hello")
-	}
-}
-
-func BenchmarkMultiThreadLog(b *testing.B) {
-	l := log.New(fakeSync.NewAdapter(), "\033[32m[DEBUG]\033[0m ", log.LstdFlags)
-	b.ResetTimer()
-
-	for i := 0; i < b.N; i++ {
-		for j := 0; j < 100; j++ {
-			go l.Println("Hello")
-		}
-	}
-}
-
-func BenchmarkMultiThreadGol(b *testing.B) {
-	g := NewLogger(level.DEBUG)
-	g.RemoveAdapter(CONSOLELOGGER)
-	g.AddLogAdapter("fake", fakeSync.NewAdapter(level.DEBUG))
-	b.ResetTimer()
 	for i := 0; i < b.N; i++ {
 		for j := 0; j < 100; j++ {
-			go g.Debug("Hello")
+			g.Debug("Hello")
 		}
 	}
 }

gollog.go

@@ -22,15 +22,15 @@ type gollog struct {
 }
 
 func (l *gollog) msgPump() {
-
-	for msg := range l.logChan {
+	var msg *logMSG
+	for msg = range l.logChan {
 
 		for _, v := range l.adapters {
 			if v.Level() <= msg.logLevel {
 				io.Copy(v, &msg.bf)
 			}
 		}
-		msgPoolPut(msg)
+		msg.bf.Reset()
 	}
 
 	close(l.doneChan)