|
|
@@ -107,6 +107,16 @@ func main() {
|
|
|
// 记录时间
|
|
|
t0 := time.Now()
|
|
|
|
|
|
+ // 打开处理器profile文件
|
|
|
+ if *cpuprofile != "" {
|
|
|
+ f, err := os.Create(*cpuprofile)
|
|
|
+ if err != nil {
|
|
|
+ log.Fatal(err)
|
|
|
+ }
|
|
|
+ pprof.StartCPUProfile(f)
|
|
|
+ defer pprof.StopCPUProfile()
|
|
|
+ }
|
|
|
+
|
|
|
// 建索引
|
|
|
log.Print("建索引 ... ")
|
|
|
docId := uint64(1)
|
|
|
@@ -143,16 +153,6 @@ func main() {
|
|
|
// 记录时间
|
|
|
t2 := time.Now()
|
|
|
|
|
|
- // 打开处理器profile文件
|
|
|
- if *cpuprofile != "" {
|
|
|
- f, err := os.Create(*cpuprofile)
|
|
|
- if err != nil {
|
|
|
- log.Fatal(err)
|
|
|
- }
|
|
|
- pprof.StartCPUProfile(f)
|
|
|
- defer pprof.StopCPUProfile()
|
|
|
- }
|
|
|
-
|
|
|
done := make(chan bool)
|
|
|
for iThread := 0; iThread < numQueryThreads; iThread++ {
|
|
|
go search(done)
|
|
|
@@ -161,11 +161,6 @@ func main() {
|
|
|
<-done
|
|
|
}
|
|
|
|
|
|
- // 停止处理器profile
|
|
|
- if *cpuprofile != "" {
|
|
|
- defer pprof.StopCPUProfile()
|
|
|
- }
|
|
|
-
|
|
|
// 记录时间并计算分词速度
|
|
|
t3 := time.Now()
|
|
|
log.Printf("搜索平均响应时间 %v 毫秒",
|