Merge pull request #10 from gochore/dev

new JobOption WithNoMutext

close #8

inner_job.go

@@ -22,6 +22,7 @@ type innerJob struct {
 	after         AfterFunc
 	retryTimes    int
 	retryInterval RetryInterval
+	noMutex       bool
 }
 
 func (j *innerJob) Key() string {
@@ -60,7 +61,7 @@ func (j *innerJob) Run() {
 	}
 
 	if !task.Skipped {
-		if j.cron.mutex == nil || j.cron.mutex.SetIfNotExists(task.Key, c.hostname) {
+		if j.noMutex || j.cron.mutex == nil || j.cron.mutex.SetIfNotExists(task.Key, c.hostname) {
 			beginAt := time.Now()
 			task.BeginAt = &beginAt
 

job_option.go

@@ -38,3 +38,9 @@ func WithRetryInterval(retryInterval RetryInterval) JobOption {
 		job.retryInterval = retryInterval
 	}
 }
+
+func WithNoMutex() JobOption {
+	return func(job *innerJob) {
+		job.noMutex = true
+	}
+}

job_option_test.go

@@ -140,3 +140,27 @@ func TestWithRetryTimes(t *testing.T) {
 		})
 	}
 }
+
+func TestWithNoMutex(t *testing.T) {
+	tests := []struct {
+		name  string
+		check func(t *testing.T, option JobOption)
+	}{
+		{
+			name: "regular",
+			check: func(t *testing.T, option JobOption) {
+				j := &innerJob{}
+				option(j)
+				if !j.noMutex {
+					t.Fatal(j.noMutex)
+				}
+			},
+		},
+	}
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			got := WithNoMutex()
+			tt.check(t, got)
+		})
+	}
+}