Made QueueMain() immune to collisions.

2015-12-21 14:26:09 -05:00 · 2015-12-21 14:26:09 -05:00 · 4b74894536
parent 01893daaf1
commit 4b74894536
1 changed files with 8 additions and 2 deletions
--- a/main.go
+++ b/main.go
@ -83,8 +83,14 @@ func QueueMain(f func()) {
 	qmlock.Lock()
 	defer qmlock.Unlock()

-	n := qmcurrent
-	qmcurrent++
+	n := uintptr(0)
+	for {
+		n = qmcurrent
+		qmcurrent++
+		if qmmap[n] == nil {
+			break
+		}
+	}
 	qmmap[n] = f
 	C.realQueueMain(unsafe.Pointer(n))
 }