Function DelayIfOverlap

cron/options.go:114–126

DelayIfOverlap returns a new JobDescriptor that will delay the job if it overlaps with another job.

()

// DelayIfOverlap returns a new JobDescriptor that will delay the job if it overlaps with another job.
func DelayIfOverlap() JobOption {
	ch := make(chan struct{}, 1)
	return func(descriptor *JobDescriptor) {
		innerRun := descriptor.Run
		descriptor.Run = func(ctx context.Context) error {
			ch <- struct{}{}
			defer func() {
				<-ch
			}()
			return innerRun(ctx)
		}
	}
}

// TimeoutIfOverlap returns a new JobDescriptor that will cancel the job's context if the next schedule is due.
func TimeoutIfOverlap() JobOption {