Documentation
¶
Overview ¶
Package background - Simple skeleton for background processes
Example ¶
// SPDX-License-Identifier: ISC
// Copyright (c) 2014-2020 Bitmark Inc.
// Use of this source code is governed by an ISC
// license that can be found in the LICENSE file.
package main
import (
"fmt"
"time"
"github.com/bitmark-inc/bitmarkd/background"
)
type theState struct {
count int
}
func main() {
proc := &theState{
count: 10,
}
// list of background processes to start
processes := background.Processes{
proc,
}
p := background.Start(processes, nil)
time.Sleep(time.Second)
p.Stop()
}
func (state *theState) Run(args interface{}, shutdown <-chan struct{}) {
fmt.Printf("initialise\n")
loop:
for {
select {
case <-shutdown:
break loop
default:
}
state.count += 1
time.Sleep(time.Millisecond)
}
fmt.Printf("finalise\n")
}
Index ¶
Examples ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Process ¶
type Process interface {
Run(args interface{}, shutdown <-chan struct{})
}
Process - type signature for background process and type that implements this Run is a process
type T ¶
T - handle type for the stop
func (*T) StopAndWait ¶ added in v0.12.0
func (t *T) StopAndWait()
StopAndWait will notify all processes to shutdown by closing shutdown channel and wait until all processes be stopped.
Click to show internal directories.
Click to hide internal directories.