@@ -12,7 +12,7 @@ const (
1212TRANSFER_CONNECTIONS = 8
1313INIT_AMOUNT = 10000
1414N_ITERATIONS = 10000
15- N_ACCOUNTS = TRANSFER_CONNECTIONS //100000
15+ N_ACCOUNTS = 100000 //TRANSFER_CONNECTIONS
1616ISOLATION_LEVEL = "repeatable read"
1717//ISOLATION_LEVEL = "read committed"
1818)
@@ -70,7 +70,7 @@ func prepare_db() {
7070exec (conn2 ,"commit" )
7171}
7272
73- func progress (total int ,cCommits chan int ,cAborts chan int ) {
73+ func progress (total int ,cCommits chan int ,cAborts chan int , wg * sync. WaitGroup ) {
7474commits := 0
7575aborts := 0
7676start := time .Now ()
@@ -86,6 +86,8 @@ func progress(total int, cCommits chan int, cAborts chan int) {
8686start = time .Now ()
8787 }
8888 }
89+ fmt .Printf ("Done: %d commits, %d aborts\n " ,commits ,aborts )
90+ wg .Done ()
8991}
9092
9193func transfer (id int ,cCommits chan int ,cAborts chan int ,wg * sync.WaitGroup ) {
@@ -164,12 +166,14 @@ func inspect(wg *sync.WaitGroup) {
164166func main () {
165167var transferWg sync.WaitGroup
166168var inspectWg sync.WaitGroup
169+ var progressWg sync.WaitGroup
167170
168171prepare_db ()
169172
170173cCommits := make (chan int )
171174cAborts := make (chan int )
172- go progress (TRANSFER_CONNECTIONS * N_ITERATIONS ,cCommits ,cAborts )
175+ progressWg .Add (1 )
176+ go progress (TRANSFER_CONNECTIONS * N_ITERATIONS ,cCommits ,cAborts ,& progressWg )
173177
174178transferWg .Add (TRANSFER_CONNECTIONS )
175179for i := 0 ;i < TRANSFER_CONNECTIONS ;i ++ {
@@ -183,7 +187,8 @@ func main() {
183187running = false
184188inspectWg .Wait ()
185189
186- fmt .Printf ("done\n " )
190+ close (cCommits )
191+ progressWg .Wait ()
187192}
188193
189194func exec (conn * pgx.Conn ,stmt string ,arguments ... interface {}) {