replace slot attempts int with atomics

internal/scheduler/scheduler.go

@@ -6,6 +6,7 @@ import (
 	"fmt"
 	"strings"
 	"sync"
+	"sync/atomic"
 	"time"
 
 	"github.com/google/uuid"
@@ -35,36 +36,32 @@ type JobSlotDetails struct {
 }
 
 type jobSlot struct {
-	l sync.RWMutex
+	*job.Job
-	job.Job
+	slot     atomic.Uint32
-	slot     int
+	attempts atomic.Uint32
-	attempts int
 	// priority Priority
 }
 
-func newJobSlot(task job.FnJob, slot int) jobSlot {
+func newJobSlot(task job.FnJob, slot int) *jobSlot {
-	return jobSlot{
+	j := job.NewJob(task)
-		Job:  job.NewJob(task),
+	js := jobSlot{
-		slot: slot,
+		Job: &j,
 	}
+
+	js.slot.Add(uint32(slot))
+
+	return &js
 }
 
 func (j *jobSlot) run(ctx context.Context) {
-	j.l.Lock()
+	j.attempts.Add(1)
-	defer j.l.Unlock()
-
-	j.attempts += 1
-
 	j.Job.Run(ctx)
 }
 
 func (j *jobSlot) getDetails() JobSlotDetails {
-	j.l.RLock()
-	defer j.l.RUnlock()
-
 	return JobSlotDetails{
 		JobDetails: j.IntoDetails(),
-		Attempts:   j.attempts,
+		Attempts:   int(j.attempts.Load()),
 	}
 }
 
@@ -175,8 +172,8 @@ func (c *SchedulerCycle) Delay(fnJob job.FnJob) uuid.UUID {
 
 	j := newJobSlot(fnJob, nextSlot)
 
-	c.slots[nextSlot] = append(c.slots[nextSlot], &j)
+	c.slots[nextSlot] = append(c.slots[nextSlot], j)
-	c.jobs[j.GetID()] = &j
+	c.jobs[j.GetID()] = j
 
 	log.Info().Str("job", j.GetID().String()).Msg("job added successfully")
 	return j.GetID()
@@ -329,6 +326,7 @@ func (c *SchedulerCycle) updateCurrentSlot(j *jobSlot) {
 	c.l.Lock()
 	defer c.l.Unlock()
 
+	j.slot.CompareAndSwap(j.slot.Load(), uint32(c.currentSlot))
 	c.slots[c.currentSlot] = append(c.slots[c.currentSlot], j)
 }