mirror of
https://github.com/zeromicro/go-zero.git
synced 2026-05-13 18:00:00 +08:00
opt: optimization of machine performance data reading (#5174)
Co-authored-by: sam.yang <sam.yang@yijinin.com>
This commit is contained in:
@@ -5,6 +5,8 @@ import (
|
|||||||
"io"
|
"io"
|
||||||
"os"
|
"os"
|
||||||
"runtime"
|
"runtime"
|
||||||
|
"runtime/debug"
|
||||||
|
"runtime/metrics"
|
||||||
"time"
|
"time"
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -28,10 +30,29 @@ func displayStatsWithWriter(writer io.Writer, interval ...time.Duration) {
|
|||||||
ticker := time.NewTicker(duration)
|
ticker := time.NewTicker(duration)
|
||||||
defer ticker.Stop()
|
defer ticker.Stop()
|
||||||
for range ticker.C {
|
for range ticker.C {
|
||||||
var m runtime.MemStats
|
var (
|
||||||
runtime.ReadMemStats(&m)
|
alloc, totalAlloc, sys uint64
|
||||||
|
samples = []metrics.Sample{
|
||||||
|
{Name: "/memory/classes/heap/objects:bytes"},
|
||||||
|
{Name: "/gc/heap/allocs:bytes"},
|
||||||
|
{Name: "/memory/classes/total:bytes"},
|
||||||
|
}
|
||||||
|
)
|
||||||
|
metrics.Read(samples)
|
||||||
|
|
||||||
|
if samples[0].Value.Kind() == metrics.KindUint64 {
|
||||||
|
alloc = samples[0].Value.Uint64()
|
||||||
|
}
|
||||||
|
if samples[1].Value.Kind() == metrics.KindUint64 {
|
||||||
|
totalAlloc = samples[1].Value.Uint64()
|
||||||
|
}
|
||||||
|
if samples[2].Value.Kind() == metrics.KindUint64 {
|
||||||
|
sys = samples[2].Value.Uint64()
|
||||||
|
}
|
||||||
|
var stats debug.GCStats
|
||||||
|
debug.ReadGCStats(&stats)
|
||||||
fmt.Fprintf(writer, "Goroutines: %d, Alloc: %vm, TotalAlloc: %vm, Sys: %vm, NumGC: %v\n",
|
fmt.Fprintf(writer, "Goroutines: %d, Alloc: %vm, TotalAlloc: %vm, Sys: %vm, NumGC: %v\n",
|
||||||
runtime.NumGoroutine(), m.Alloc/mega, m.TotalAlloc/mega, m.Sys/mega, m.NumGC)
|
runtime.NumGoroutine(), alloc/mega, totalAlloc/mega, sys/mega, stats.NumGC)
|
||||||
}
|
}
|
||||||
}()
|
}()
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,7 +1,8 @@
|
|||||||
package stat
|
package stat
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"runtime"
|
"runtime/debug"
|
||||||
|
"runtime/metrics"
|
||||||
"sync/atomic"
|
"sync/atomic"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
@@ -56,8 +57,28 @@ func bToMb(b uint64) float32 {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func printUsage() {
|
func printUsage() {
|
||||||
var m runtime.MemStats
|
var (
|
||||||
runtime.ReadMemStats(&m)
|
alloc, totalAlloc, sys uint64
|
||||||
|
samples = []metrics.Sample{
|
||||||
|
{Name: "/memory/classes/heap/objects:bytes"},
|
||||||
|
{Name: "/gc/heap/allocs:bytes"},
|
||||||
|
{Name: "/memory/classes/total:bytes"},
|
||||||
|
}
|
||||||
|
stats debug.GCStats
|
||||||
|
)
|
||||||
|
metrics.Read(samples)
|
||||||
|
|
||||||
|
if samples[0].Value.Kind() == metrics.KindUint64 {
|
||||||
|
alloc = samples[0].Value.Uint64()
|
||||||
|
}
|
||||||
|
if samples[1].Value.Kind() == metrics.KindUint64 {
|
||||||
|
totalAlloc = samples[1].Value.Uint64()
|
||||||
|
}
|
||||||
|
if samples[2].Value.Kind() == metrics.KindUint64 {
|
||||||
|
sys = samples[2].Value.Uint64()
|
||||||
|
}
|
||||||
|
debug.ReadGCStats(&stats)
|
||||||
|
|
||||||
logx.Statf("CPU: %dm, MEMORY: Alloc=%.1fMi, TotalAlloc=%.1fMi, Sys=%.1fMi, NumGC=%d",
|
logx.Statf("CPU: %dm, MEMORY: Alloc=%.1fMi, TotalAlloc=%.1fMi, Sys=%.1fMi, NumGC=%d",
|
||||||
CpuUsage(), bToMb(m.Alloc), bToMb(m.TotalAlloc), bToMb(m.Sys), m.NumGC)
|
CpuUsage(), bToMb(alloc), bToMb(totalAlloc), bToMb(sys), stats.NumGC)
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user