Compare commits
2 Commits
d6c3f542f3
...
v1.3.28
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
9fb0513703 | ||
|
|
7b96919d80 |
@@ -26,7 +26,7 @@ var (
|
||||
Name = "game_act"
|
||||
ActList = gset.New(true)
|
||||
RunTimeMax *gtime.Time
|
||||
TaskMax int64 = 5
|
||||
TaskMax int64 = 100
|
||||
)
|
||||
|
||||
type sGameAct struct {
|
||||
@@ -605,6 +605,8 @@ func (s *sGameAct) Cache2SqlChan(ctx context.Context, addChan, updateChan chan *
|
||||
}
|
||||
|
||||
err = tx.Commit()
|
||||
addAllCount += addCount
|
||||
updateAllCount += updateCount
|
||||
// 仅在所有通道处理完毕后打印最终计数(移除中间冗余日志)
|
||||
g.Log().Debugf(ctx, "运行结束act当前写入数据库: %v 条", addAllCount)
|
||||
g.Log().Debugf(ctx, "运行结束act当前更新数据库: %v 条", updateAllCount)
|
||||
|
||||
Reference in New Issue
Block a user