changing to second precision

README.md

@@ -50,11 +50,11 @@ func main() {
 ## Prerequisites
 
 - The table cron_job_locks needs to exist in the database. This can be achieved, as an example, using gorm automigrate functionality `db.Automigrate(&CronJobLock{})`
-- In order to uniquely identify the job, the locker uses the unique combination of the job name + timestamp (by default with precision to miliseconds).
+- In order to uniquely identify the job, the locker uses the unique combination of the job name + timestamp (by default with precision to seconds).
 
 ## FAQ
 
-- Q: The locker uses the unique combination of the job name + timestamp with miliseconds precision, how can I change that?
+- Q: The locker uses the unique combination of the job name + timestamp with seconds precision, how can I change that?
   - A: It's possible to set how to create the job identifier, here is an example to set an hour precision:
     ```go
 	locker, err := gormlock.NewGormLocker(db, "local",

gormlock.go

@@ -8,7 +8,7 @@ import (
 	"gorm.io/gorm"
 )
 
-var defaultPrecision = time.Millisecond
+var defaultPrecision = time.Second
 
 func NewGormLocker(db *gorm.DB, worker string, options ...LockOption) (gocron.Locker, error) {
 	gl := &gormLocker{db: db, worker: worker}

gormlock_test.go

@@ -39,38 +39,30 @@ func TestEnableDistributedLocking(t *testing.T) {
 	resultChan := make(chan int, 10)
 	f := func(schedulerInstance int) {
 		resultChan <- schedulerInstance
+		println(time.Now().Truncate(defaultPrecision).Format("2006-01-02 15:04:05.000"))
 	}
 
-	s1 := gocron.NewScheduler(time.UTC)
 	l1, err := NewGormLocker(db, "s1")
 	require.NoError(t, err)
+	s1 := gocron.NewScheduler(time.UTC)
 	s1.WithDistributedLocker(l1)
-	_, err = s1.Every("500ms").Do(f, 1)
+	_, err = s1.Every("1s").Do(f, 1)
 	require.NoError(t, err)
 
-	s2 := gocron.NewScheduler(time.UTC)
 	l2, err := NewGormLocker(db, "s2")
 	require.NoError(t, err)
+	s2 := gocron.NewScheduler(time.UTC)
 	s2.WithDistributedLocker(l2)
-	_, err = s2.Every("500ms").Do(f, 2)
-	require.NoError(t, err)
-
-	s3 := gocron.NewScheduler(time.UTC)
-	l3, err := NewGormLocker(db, "s3")
-	require.NoError(t, err)
-	s3.WithDistributedLocker(l3)
-	_, err = s3.Every("500ms").Do(f, 3)
+	_, err = s2.Every("1s").Do(f, 2)
 	require.NoError(t, err)
 
 	s1.StartAsync()
 	s2.StartAsync()
-	s3.StartAsync()
 
-	time.Sleep(1700 * time.Millisecond)
+	time.Sleep(3500 * time.Millisecond)
 
 	s1.Stop()
 	s2.Stop()
-	s3.Stop()
 	close(resultChan)
 
 	var results []int
@@ -118,18 +110,18 @@ func TestEnableDistributedLocking_DifferentJob(t *testing.T) {
 	l1, err := NewGormLocker(db, "s1")
 	require.NoError(t, err)
 	s1.WithDistributedLocker(l1)
-	_, err = s1.Every("500ms").Name("f").Do(f, 1)
+	_, err = s1.Every("1s").Name("f").Do(f, 1)
 	require.NoError(t, err)
-	_, err = s1.Every("500ms").Name("f2").Do(f2, 1)
+	_, err = s1.Every("1s").Name("f2").Do(f2, 1)
 	require.NoError(t, err)
 
 	s2 := gocron.NewScheduler(time.UTC)
 	l2, err := NewGormLocker(db, "s2")
 	require.NoError(t, err)
 	s2.WithDistributedLocker(l2)
-	_, err = s2.Every("500ms").Name("f").Do(f, 2)
+	_, err = s2.Every("1s").Name("f").Do(f, 2)
 	require.NoError(t, err)
-	_, err = s2.Every("500ms").Name("f2").Do(f2, 2)
+	_, err = s2.Every("1s").Name("f2").Do(f2, 2)
 	require.NoError(t, err)
 
 	s3 := gocron.NewScheduler(time.UTC)
@@ -145,7 +137,7 @@ func TestEnableDistributedLocking_DifferentJob(t *testing.T) {
 	s2.StartAsync()
 	s3.StartAsync()
 
-	time.Sleep(1700 * time.Millisecond)
+	time.Sleep(3500 * time.Millisecond)
 
 	s1.Stop()
 	s2.Stop()