LazyGophers Utils
  • English

      • routine - Goroutine Management

      Overview

      The routine module provides goroutine management utilities including worker pools, task scheduling, and panic recovery.

      Functions

      Go()

      Execute function in a goroutine with panic recovery.

      func Go(f func() (err error))

      Parameters:

      • f - Function to execute

      Behavior:

      • Executes function in a goroutine
      • Logs errors if function returns error
      • Automatically manages trace IDs

      Example:

      routine.Go(func() error {
    if err := processData(); err != nil {
        return err
    }
    return nil
})

      GoWithRecover()

      Execute function in a goroutine with full panic recovery.

      func GoWithRecover(f func() (err error))

      Parameters:

      • f - Function to execute

      Behavior:

      • Executes function in a goroutine
      • Catches panics and logs stack trace
      • Logs errors if function returns error

      Example:

      routine.GoWithRecover(func() error {
    // This will be caught and logged
    panic("Something went wrong")
    return nil
})

      GoWithMustSuccess()

      Execute function in a goroutine with panic on error.

      func GoWithMustSuccess(f func() (err error))

      Parameters:

      • f - Function to execute

      Behavior:

      • Executes function in a goroutine
      • Exits process if function returns error

      Example:

      routine.GoWithMustSuccess(func() error {
    if err := criticalOperation(); err != nil {
        return err
    }
    return nil
})
// Process will exit if criticalOperation fails

      AddBeforeRoutine()

      Add callback to execute before goroutine starts.

      func AddBeforeRoutine(f BeforeRoutine)

      Parameters:

      • f - Callback function

      Example:

      routine.AddBeforeRoutine(func(baseGid, currentGid int64) {
    log.Infof("Starting goroutine: %d -> %d", baseGid, currentGid)
})

      AddAfterRoutine()

      Add callback to execute after goroutine completes.

      func AddAfterRoutine(f AfterRoutine)

      Parameters:

      • f - Callback function

      Example:

      routine.AddAfterRoutine(func(currentGid int64) {
    log.Infof("Completed goroutine: %d", currentGid)
})

      Usage Patterns

      Background Tasks

      func startBackgroundTasks() {
    routine.Go(func() error {
        ticker := time.NewTicker(time.Minute)
        defer ticker.Stop()
        
        for range ticker.C {
            if err := performMaintenance(); err != nil {
                log.Errorf("Maintenance failed: %v", err)
            }
        }
        return nil
    })
}

      Error Handling

      func safeAsyncOperation() {
    routine.GoWithRecover(func() error {
        // This panic will be caught
        if someCondition {
            panic("Unexpected error")
        }
        return nil
    })
}

      Task Scheduling

      func scheduleTask(delay time.Duration, task func()) {
    routine.Go(func() error {
        time.Sleep(delay)
        task()
        return nil
    })
}

      Best Practices

      Error Recovery

      // Good: Use GoWithRecover for critical goroutines
routine.GoWithRecover(func() error {
    criticalOperation()
    return nil
})

// Good: Use Go for simple tasks
routine.Go(func() error {
    simpleOperation()
    return nil
})