source: doc/theses/colby_parsons_MMAth/benchmarks/actors/proto/SendDynamic/GoSendDynamic.go @ fb7cda9

// https://github.com/asynkron/protoactor-go
// https://pkg.go.dev/github.com/asynkron/protoactor-go/actor
package main

import (
        "os"; "strconv"; "fmt"; "time"; "runtime"
        "github.com/asynkron/protoactor-go/actor"
)

var Times int = 2_000_000;
var start time.Time;
var shake = make( chan string )
var system * actor.ActorSystem

type Msg struct { cnt int }
type Send struct{}

func ( state * Send ) Receive( context actor.Context ) {
        switch msg := context.Message().(type) {
          case * Msg:
                if msg.cnt >= Times  {
                        fmt.Printf( "%v\n", int64(time.Since(start) / time.Duration(Times) / time.Nanosecond) );
                        shake <- "hand"
                        return;
                } // if
                //fmt.Printf( "Send %v\n", msg.cnt );
                props := actor.PropsFromProducer( func() actor.Actor { return &Send{} } )
                pid := system.Root.Spawn( props )
                system.Root.Send( pid, &Msg{ msg.cnt + 1 } );
                system.Root.Stop( context.Self() );
          default:
                // ignore actor.Started message
        }
}

func usage() {
        fmt.Printf( "Usage: %v [ times (> 0) ]\n", os.Args[0] );
        os.Exit( 1 );
}

func main() {
        switch len( os.Args ) {
          case 2:
                if os.Args[1] != "d" { Times, _ = strconv.Atoi( os.Args[1] ) }
                if Times < 1 { usage(); }
          case 1:                                                                                       // use defaults
          default:
                usage();
        } // switch

        runtime.GOMAXPROCS(1);
        system = actor.NewActorSystem();
        props := actor.PropsFromProducer( func() actor.Actor { return &Send{} } );
        pid := system.Root.Spawn(props);
        start = time.Now();
        system.Root.Send( pid, &Msg{ 0 } );
        <- shake
}

// /usr/bin/time -f "%Uu %Ss %Er %Mkb" GoSendDynamic

// Local Variables: //
// tab-width: 4 //
// compile-command: "go build" //
// End: //