add runtime.Gosched() to store method

dotbitHQ · Oct 19, 2021 · 7497b1c · 7497b1c
1 parent f79bf40
commit 7497b1c
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/cmd/main.go b/cmd/main.go
@@ -159,7 +159,6 @@ func runServer(ctx *cli.Context) error {
 						}
 					}
 				}
-				runtime.Gosched()
 				time.Sleep(time.Second)
 			}
 		}()

diff --git a/parser/handler/common.go b/parser/handler/common.go
@@ -6,6 +6,7 @@ import (
 	"fmt"
 	"github.com/DeAccountSystems/das_commonlib/common/rocksdb"
 	"github.com/tecbot/gorocksdb"
+	"runtime"
 )
 
 /**
@@ -165,6 +166,7 @@ func storeAccountInfoToRocksDb(db *gorocksdb.DB, writeBatch *gorocksdb.WriteBatc
 			log.Info(fmt.Sprintf(
 				"storeAccountInfoToRocksDb, add new item, account: %s, id: %s, owner: %s",
 				item.AccountData.Account, item.AccountData.AccountIdHex, item.AccountData.OwnerLockArgsHex))
+			runtime.Gosched()
 			putsItem(ownerLockArgsHexKey, &item, &newList)
 		}
 	}