figure_2.go

package main

import (
    "context"
    "runtime"
    "strings"
    "time"
)

// main simulates the memory use of a general RPC server.
func main() {
    // Simulate request serving by repeatedly allocating memory,
    // sleeping to simulate the server's work, and then removing
    // the reference to the allocated memory.

    const requestConcurrency = 128
    const totalMemorySize = 64 * 1024 * 1024
    const requestMemorySize = totalMemorySize / requestConcurrency
    const requestProcessingDuration = 100 * time.Millisecond

    for i := 0; i < requestConcurrency; i++ {
        go func() {
            for {
                requestData := strings.Repeat("a", requestMemorySize)
                time.Sleep(requestProcessingDuration)

                // Reference requestData to keep it from being
                // collected until the simulated request is complete.
                runtime.KeepAlive(requestData)
            }
        }()
    }

    // Run the request processing without end.
    <-context.Background().Done()
}