go-application

Go application

start an application

func run1(ctx context.Context) {
	for {
		select {
		case <-ctx.Done():
			// done, exit loop now
			return
		default:
		}
	}
}

func run2(ctx context.Context) {
	for {
		select {
		case <-ctx.Done():
			// done, exit loop now
			return
		default:
		}
	}
}


func main() {
app := application.NewApplication(nil)
app.Start(run1)  // start a goroutine for run1
app.Start(run2)  // start a goroutine for run2
app.Background()  // wait until ctrl-c is pressed
}

func main() {
	ctx, cancel := context.WithTimeout(context.Background(), time.Hour)
	defer cancel()
	app := application.NewApplication(ctx)
	app.Start(run1)  // start a goroutine for run1
	app.Start(run2)  // start a goroutine for run2
	app.Wait() // wait until run1 & run2 completed, or after 1 hr

Executor

func afunc(ctx context.Context, data interface{}) {
	// the function to be called later
}

// start 10 goroutines to execute the given func
executor := application.NewExecutor(context.Background(), 10)

// submit afunc to be call later after a second
executor.ExecuteLater(ctx, afunc, nil, time.Second)

// submit afunc to be called by the 10 goroutine
executor.Submit(ctx, afunc, nil)