Skip to content

Commit

Permalink
article: add bench-time
Browse files Browse the repository at this point in the history
  • Loading branch information
changkun committed Oct 2, 2020
1 parent c65afec commit e1e0e18
Show file tree
Hide file tree
Showing 6 changed files with 371 additions and 0 deletions.
9 changes: 9 additions & 0 deletions README.md
Original file line number Diff line number Diff line change
@@ -1,2 +1,11 @@
# research

(Possibly) Naïve thoughts regarding Go.

## Table of Content

- [Changkun Ou. Eliminating A Source of Measurement Errors in Benchmarks. Sep 30, 2020.](./bench-time.md)

## License

Copyright © 2020 The [golang.design](https://golang.design) Authors.
Binary file added assets/bench-time-pprof1.png
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
Binary file added assets/bench-time-pprof2.png
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
Binary file added assets/bench-time.graffle
Binary file not shown.
Binary file added assets/bench-time.png
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
362 changes: 362 additions & 0 deletions bench-time.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,362 @@
# Eliminating A Source of Measurement Errors in Benchmarks

Author(s): [Changkun Ou](https://changkun.de)

Last updated: 2020-09-30

## Introduction

About six months ago, I did a [presentation](https://golang.design/s/gobench)
that talks about how to conduct a reliable benchmark in Go.
Recently, I submitted an issue [#41641](https://golang.org/issue/41641) to the Go project, which is also a subtle issue that you might need to address in some cases.

It is all about the following code snippet:

```go
func BenchmarkAtomic(b *testing.B) {
var v int32
atomic.StoreInt32(&v, 0)
b.Run("with-timer", func(b *testing.B) {
for i := 0; i < b.N; i++ {
b.StopTimer()
// ... do extra stuff ...
b.StartTimer()
atomic.AddInt32(&v, 1)
}
})
atomic.StoreInt32(&v, 0)
b.Run("w/o-timer", func(b *testing.B) {
for i := 0; i < b.N; i++ {
atomic.AddInt32(&v, 1)
}
})
}
```

On my target machine (CPU Quad-core Intel Core i7-7700 (-MT-MCP-) speed/max 1341/4200 MHz Kernel 5.4.0-42-generic x86_64), running this snippet with the following command:

```
go test -run=none -bench=Atomic -benchtime=1000x -count=20 | tee b.txt && benchstat b.txt
```

The result shows:

```
name time/op
Atomic/with-timer-8 32.6ns ± 7%
Atomic/w/o-timer-8 6.60ns ± 6%
```

Is it interesting to you? As you can see, the measurement without introducing `StopTimer/StartTimer` is 26ns faster than with the `StopTimer/StartTimer` pair.
So, how is this happening?

To dig more reason behind it, let's modify the snippet a little bit:

```go
func BenchmarkAtomic(b *testing.B) {
var v int32
var n = 1000000
for k := 1; k < n; k *= 10 {
b.Run(fmt.Sprintf("n-%d", k), func(b *testing.B) {
atomic.StoreInt32(&v, 0)
b.Run("with-timer", func(b *testing.B) {
for i := 0; i < b.N; i++ {
b.StopTimer()
b.StartTimer()
for j := 0; j < k; j++ {
atomic.AddInt32(&v, 1)
}
}
})
atomic.StoreInt32(&v, 0)
b.Run("w/o-timer", func(b *testing.B) {
for i := 0; i < b.N; i++ {
for j := 0; j < k; j++ {
atomic.AddInt32(&v, 1)
}
}
})
})
}
}
```

This time, we use the `k` to increase the number of atomic operations in the bench loop, i.e.:

```go
for j := 0; j < k; j++ {
atomic.AddInt32(&v, 1)
}
```

Thus with higher `k`, the target code grows more costly. With similar command:

```
go test -run=none -bench=Atomic -benchtime=1000x -count=20 | tee b.txt && benchstat b.txt
```

```
name time/op
Atomic/n-1/with-timer-8 34.8ns ±12%
Atomic/n-1/w/o-timer-8 6.44ns ± 1%
Atomic/n-10/with-timer-8 74.3ns ± 5%
Atomic/n-10/w/o-timer-8 47.6ns ± 3%
Atomic/n-100/with-timer-8 488ns ± 7%
Atomic/n-100/w/o-timer-8 456ns ± 2%
Atomic/n-1000/with-timer-8 4.65µs ± 3%
Atomic/n-1000/w/o-timer-8 4.63µs ±12%
Atomic/n-10000/with-timer-8 45.4µs ± 4%
Atomic/n-10000/w/o-timer-8 43.5µs ± 1%
Atomic/n-100000/with-timer-8 444µs ± 1%
Atomic/n-100000/w/o-timer-8 432µs ± 0%
```

What's interesting in the modified benchmark result is by testing target code with a higher cost,
the difference between `with-timer` and `w/o-timer` gets much closer. For instance, in the last pair of output when `n=100000`, the measured atomic operation only has `(444µs-432µs)/100000 = 0.12 ns` difference, which is pretty much accurate other than when `n=1` the error is `(34.8ns-6.44ns)/1 = 28.36 ns`.

So, how is this happening? There are two ways to trace the problem down to the bare bones.

<!--more-->

## Initial Investigation Using `go tool pprof`

As a standard procedure, let's benchmark the code that interrupts the timer and analysis the result using `go tool pprof`:

```go
func BenchmarkWithTimer(b *testing.B) {
var v int32
for i := 0; i < b.N; i++ {
b.StopTimer()
b.StartTimer()
for j := 0; j < *k; j++ {
atomic.AddInt32(&v, 1)
}
}
}
```

```
go test -v -run=none -bench=WithTimer -benchtime=100000x -count=5 -cpuprofile cpu.pprof
```

Sadly, the graph shows a chunk of useless information where most of the costs shows as `runtime.ReadMemStats`:

![pprof](./assets/bench-time-pprof1.png)

This is because of the `StopTimer/StartTimer` implementation in the testing package calls `runtime.ReadMemStats`:

```go
package testing

(...)

func (b *B) StartTimer() {
if !b.timerOn {
runtime.ReadMemStats(&memStats) // <- here
b.startAllocs = memStats.Mallocs
b.startBytes = memStats.TotalAlloc
b.start = time.Now()
b.timerOn = true
}
}

func (b *B) StopTimer() {
if b.timerOn {
b.duration += time.Since(b.start)
runtime.ReadMemStats(&memStats) // <- here
b.netAllocs += memStats.Mallocs - b.startAllocs
b.netBytes += memStats.TotalAlloc - b.startBytes
b.timerOn = false
}
}
```

As we know that `runtime.ReadMemStats` stops the world, and each call to it is very time-consuming. This is an known issue [#20875](https://golang.org/issue/20875) regarding `runtime.ReadMemStats` in benchmarking.

Since we do not care about memory allocation at the moment, to avoid this issue, let's just hacking the source code by just comment out the call to `runtime.ReadMemStats`:

```go
package testing

(...)

func (b *B) StartTimer() {
if !b.timerOn {
// runtime.ReadMemStats(&memStats) // <- here
b.startAllocs = memStats.Mallocs
b.startBytes = memStats.TotalAlloc
b.start = time.Now()
b.timerOn = true
}
}

func (b *B) StopTimer() {
if b.timerOn {
b.duration += time.Since(b.start)
// runtime.ReadMemStats(&memStats) // <- here
b.netAllocs += memStats.Mallocs - b.startAllocs
b.netBytes += memStats.TotalAlloc - b.startBytes
b.timerOn = false
}
}
```

And re-run the test again, then we have:

![pprof](./assets/bench-time-pprof2.png)

Have you noticed where the problem is? Yes, there is a heavy cost in calling `time.Now()` in a tight loop (not really surprising because it is a system call).

## Further Verification Using C++

As you can see, the Go's pprof facility has its own problem while doing a benchmark,
one can only edit the source code of Go to verify the source of the measurement error.
Can we do something better than that?

Let's just write the initial benchmark in C++. This time, we go straightforward to the issue of `now()`:

```cpp
#include <iostream>
#include <chrono>

void empty() {}

int main() {
int n = 1000000;
for (int j = 0; j < 10; j++) {
std::chrono::nanoseconds since(0);
for (int i = 0; i < n; i++) {
auto start = std::chrono::steady_clock::now();
empty();
since += std::chrono::steady_clock::now() - start;
}
std::cout << "avg since: " << since.count() / n << "ns \n";
}
}
```

compile it with:

```
clang++ -std=c++17 -O3 -pedantic -Wall main.cpp
```

In this code snippet, we are trying to measure the performance of an empty function.
So, ideally, the output should be `0ns`. However, there is still a cost in calling
the empty function:

```
avg since: 17ns
avg since: 16ns
avg since: 16ns
avg since: 16ns
avg since: 16ns
avg since: 16ns
avg since: 16ns
avg since: 16ns
avg since: 16ns
avg since: 16ns
```

Furthermore, we could just simplify the code to the subtraction of two `now()` calls:

```cpp
#include <iostream>
#include <chrono>

int main() {
int n = 1000000;
for (int j = 0; j < 10; j++) {
std::chrono::nanoseconds since(0);
for (int i = 0; i < n; i++) {
since -= std::chrono::steady_clock::now() - std::chrono::steady_clock::now();
}
std::cout << "avg since: " << since.count() / n << "ns \n";
}
}
```

and you could see that the output remains end in the cost of `avg since: 16ns`.
**This proves that there is an overhead of calling `now()` for benchmarking.**
Thus, in terms of benchmarking, the actual measured time of a target code equals
to the execution time of target code plus the overhead of calling `now()`:

<p align="center">
<img src="./assets/bench-time.png">
</p>

Assume the target code consumes in `T` ns, and the overhead of `now()` is `t` ns.
Now, let's run the target code `N` times.
The total measured time is `T*N+t`, then the average of a single iteration
of the target code is `T+t/N`. Thus, the systematic measurement error becomes: `t/N`.
Therefore with a higher `N`, you can get rid of the systematic error.

## The Solution

So, back to the original question, how can I get address the measurement error?
A quick and dirty solution is just subtract the overhead of calling `now()`:

```cpp
#include <iostream>
#include <chrono>

void target() {}

int main() {
int n = 1000000;
for (int j = 0; j < 10; j++) {
std::chrono::nanoseconds since(0);
for (int i = 0; i < n; i++) {
auto start = std::chrono::steady_clock::now();
target();
since += std::chrono::steady_clock::now() - start;
}

auto overhead = -(std::chrono::steady_clock::now() -
std::chrono::steady_clock::now());
since -= overhead * n;

std::cout << "avg since: " << since.count() / n << "ns \n";
}
}
```

And in Go, you could do:

```go
var v int32
atomic.StoreInt32(&v, 0)
r := testing.Benchmark(func(b *testing.B) {
for i := 0; i < b.N; i++ {
b.StopTimer()
// ... do extra stuff ...
b.StartTimer()
atomic.AddInt32(&v, 1)
}
})

// do calibration that removes the overhead of calling time.Now().
calibrate := func(d time.Duration, n int) time.Duration {
since := time.Duration(0)
for i := 0; i < n; i++ {
start := time.Now()
since += time.Since(start)
}
return (d - since) / time.Duration(n)
}

fmt.Printf("%v ns/op\n", calibrate(r.T, r.N))
```

As a take-away message, if you would like to write a micro-benchmark (whose runs in nanoseconds), and you have to interrupt the timer to clean up and reset some resources for some reason, then you must do a calibration on the measurement. If the Go's benchmark facility plans to fix #41641, then it is great; but if they don't, at least you are aware of this issue and know how to fix it now.

## Further Reading Suggestions

- Changkun Ou. Conduct Reliable Benchmarking in Go. March 26, 2020. https://golang.design/s/gobench
- Changkun Ou. testing: inconsistent benchmark measurements when interrupts timer. Sep 26, 2020. https://golang.org/issue/41641
- Josh Bleecher Snyder. testing: consider calling ReadMemStats less during benchmarking. Jul 1, 2017. https://golang.org/issue/20875
- Beyer, D., Löwe, S. & Wendler, P. Reliable benchmarking: requirements and solutions. Int J Softw Tools Technol Transfer 21, 1–29 (2019). https://doi.org/10.1007/s10009-017-0469-y

## License

Copyright &copy; 2020 The [golang.design](https://golang.design) Authors.

0 comments on commit e1e0e18

Please sign in to comment.