package main import ( "fmt" "os" "runtime" "sync" "time" "unsafe" "git.wow.st/gmp/nswrap/examples/strings/ns" ) func incr() func(bool) (int, float64) { i := 0 b := 0.0 var mx sync.Mutex return func(bad bool) (int, float64) { mx.Lock() if bad { b++ defer mx.Unlock() } else { defer func() { i++; mx.Unlock() }() } if b == 0 { return i, 0.0 } else { return i, (b / float64(i)) * 100 } } } type tracker struct { add, drop func(*ns.Id) check func() i func(bool) (int, float64) } type record struct { ptr unsafe.Pointer goPtr *ns.Id when time.Time } func newTracker() (func(*ns.Id), func(*ns.Id), func()) { addch := make(chan *ns.Id) dropch := make(chan *ns.Id) data := []record{} var mux sync.Mutex go func() { for { select { case x := <-addch: mux.Lock() data = append(data, record{ x.Ptr(), x, time.Now(), }) mux.Unlock() case x := <-dropch: mux.Lock() data = append(data, record{ nil, x, time.Now(), }) mux.Unlock() } } }() add := func(x *ns.Id) { addch <- x } drop := func(x *ns.Id) { dropch <- x } check := func() { live := map[unsafe.Pointer]*ns.Id{} bad := false mux.Lock() for _, r := range data { if r.ptr != nil { if live[r.ptr] != nil { fmt.Printf("COLLISION: %p & %p -> %p\n", r.goPtr, live[r.ptr], r.ptr) bad = true } live[r.ptr] = r.goPtr } else { delete(live, r.ptr) } } fmt.Printf("Checked %d records -- ", len(data)) if bad { fmt.Printf("failed\n") } else { fmt.Printf("ok\n") } mux.Unlock() } return add, drop, check } func mkstrings(t tracker) { for { //fmt.Printf("main thread: %t\n",ns.NSThreadIsMainThread()) x, b := t.i(false) str := fmt.Sprintf("string %d", x) s := ns.NSStringWithGoString(str) //t.add(&s.Id) for j := 0; j < 10; j++ { sout := s.String() if str != sout { _, b = t.i(true) fmt.Printf("%3.2f%% -- %d: '%s' '%s'\n", b, x, str, sout) } time.Sleep(time.Second / 1000) } if x%1000 == 0 { fmt.Printf("%3.2f%% -- %s\n", b, time.Now().Format("03:04:05.000")) } //t.drop(&s.Id) } } func main() { runtime.GOMAXPROCS(4) fmt.Printf("Starting\n") //ns.NSThreadNew().Start() fmt.Printf("multithreaded: %t\n", ns.NSThreadIsMultiThreaded()) //pool := ns.NSAutoreleasePoolAlloc() add, drop, check := newTracker() i := tracker{add, drop, check, incr()} go mkstrings(i) go mkstrings(i) go mkstrings(i) go mkstrings(i) go mkstrings(i) go mkstrings(i) go mkstrings(i) go mkstrings(i) go func() { for { runtime.GC() time.Sleep(time.Second / 100) } }() time.Sleep(time.Second * 600) i.check() //pool.Drain() os.Exit(0) }