Subversion Repositories openrisc

// Copyright 2011 The Go Authors. All rights reserved.

// Use of this source code is governed by a BSD-style

// license that can be found in the LICENSE file.

package runtime_test

import (

        "runtime"

        "sync"

        "sync/atomic"

        "testing"

)

func fin(v *int) {

}

func BenchmarkFinalizer(b *testing.B) {

        const CallsPerSched = 1000

        procs := runtime.GOMAXPROCS(-1)

        N := int32(b.N / CallsPerSched)

        var wg sync.WaitGroup

        wg.Add(procs)

        for p := 0; p < procs; p++ {

                go func() {

                        var data [CallsPerSched]*int

                        for i := 0; i < CallsPerSched; i++ {

                                data[i] = new(int)

                        }

                        for atomic.AddInt32(&N, -1) >= 0 {

                                runtime.Gosched()

                                for i := 0; i < CallsPerSched; i++ {

                                        runtime.SetFinalizer(data[i], fin)

                                }

                                for i := 0; i < CallsPerSched; i++ {

                                        runtime.SetFinalizer(data[i], nil)

                                }

                        }

                        wg.Done()

                }()

        }

        wg.Wait()

}

func BenchmarkFinalizerRun(b *testing.B) {

        const CallsPerSched = 1000

        procs := runtime.GOMAXPROCS(-1)

        N := int32(b.N / CallsPerSched)

        var wg sync.WaitGroup

        wg.Add(procs)

        for p := 0; p < procs; p++ {

                go func() {

                        for atomic.AddInt32(&N, -1) >= 0 {

                                runtime.Gosched()

                                for i := 0; i < CallsPerSched; i++ {

                                        v := new(int)

                                        runtime.SetFinalizer(v, fin)

                                }

                                runtime.GC()

                        }

                        wg.Done()

                }()

        }

        wg.Wait()

}