/**
     * Runs the given action as a worker. While the action is running, the thread can acquire resource locks.
     * A worker lease is also granted to the thread. The thread can release this if it needs to, but should reacquire
     * the lease prior to doing any meaningful work.
     *
     * This method is reentrant so that a thread can call this method from the given action.
     *
     * This method blocks until a worker lease is available.

Michael Anthony Knyszek <******@****.***> 1716583527 +0000

Carlos Amedee <******@****.***> 1715265901 -0400

}

func (q *Queue) resetTimer() {
	// Below is a separate function to limit the scope of the lock.
	// We don't want to lock when we modify the timer in case it causes
	// an immediate callback, which would reacquire the lock.
	needReset, resetDuration := func() (bool, time.Duration) {
		q.mutex.Lock()
		defer q.mutex.Unlock()

		if q.stopping {
			// Ignore the event, since we're already shutting down.
			return false, 0

                }
            }
        }

        then:
        instant.worker1Finished > instant.unlocked
    }

    def "releases worker lease when replacing locks and need to block to reacquire an old lock"() {
        def registry = workerLeaseService(1)
        def resource1 = resourceLock("one")
        def resource2 = resourceLock("two")

        when:
        async {
            start {

Michael Anthony Knyszek <******@****.***> 1716583527 +0000

Michael Anthony Knyszek <******@****.***> 1716583527 +0000

Carlos Amedee <******@****.***> 1715265901 -0400

Carlos Amedee <******@****.***> 1715265901 -0400

Carlos Amedee <******@****.***> 1715265901 -0400