Systems and methods for semaphore synchronization
A system for controlling shared computing resources is provided including a semaphore for controlling concurrent access to one or more computing resources by one or more worker processing threads, the semaphore including a semaphore counter corresponding to vacancies of one or more computing resources and a semaphore queue for resource requests of the one or more worker processing threads waiting for the one or more computing resources. The semaphore is programmed and configured to decrement the semaphore counter when allocating one of the computing resources to one of the worker threads and configured to increment the semaphore counter when releasing one of the computing resources from one of the worker threads. The semaphore increments the queue of requests from the one or more worker threads if a request for resource access occurs when the counter of the semaphore counter is zero or less than zero. The semaphore counter is decremented when receiving a force decrement command for reducing the number of computing resources allocable to the worker threads and is not forced to wait in a working queue for the decrement to occur. If the counter is zero or less than zero at the time of the force decrement command, the semaphore counter will further decrease in value.
1. A system for controlling shared computing resources comprising:
at least one processor operatively coupled to a memory, the at least one processor being configured to instantiate a semaphore for controlling concurrent access to one or more computing resources by one or more worker threads, the semaphore comprising a semaphore counter corresponding to vacancies of the one or more computing resources and a semaphore queue for resource requests of the one or more worker threads, the semaphore programmed and configured to:
decrement the semaphore counter when allocating any of the one or more computing resources to one of the one or more worker threads;
increment the semaphore counter when releasing any of the one or more computing resources from one of the one or more worker threads;
increment the semaphore counter if a request for resource access occurs when the semaphore counter is zero or less than zero; and
decrement the semaphore counter when receiving a force decrement command from a control thread for reducing a number of computing resources allocable to the one or more worker threads, wherein the semaphore counter will decrease to a negative integer value if the semaphore counter is zero or less than zero at a time of the force decrement command.
2. The system of claim 1 wherein upon decreasing the semaphore counter to a negative integer value, one of the one or more computing resources is deallocated for use by the one or more worker threads prior to any reallocation of the one of the one or more computing resources to the one or more worker threads.
3. The system of claim 1 wherein the one or more computing resources are dedicated to processing data storage requests from the one or more worker threads and the semaphore counter indicates a count of concurrently available data storage segments available for the one or more worker threads.
4. The system of claim 1 wherein the semaphore queue corresponds to a number of resources that need to be requested prior to processing the resource requests of the one or more worker threads.
5. The system of claim 4 wherein the one or more computing resources are dedicated to writing data from cache memory, the one or more worker threads are destagers, and the semaphore counter represents a destager queue size that triggers a release of threads waiting in the semaphore queue.
6. The system of claim 5 wherein upon the semaphore receiving and processing the force decrement command between a time that any of the one or more worker threads decrements the semaphore counter and before the worker thread removes an entry from a working queue, the semaphore counter will be incremented to correct for a double decrement.
7. A method for sharing computing resources comprising:
providing a semaphore for controlling concurrent access to one or more computing resources by one or more worker threads, the semaphore comprising a semaphore counter corresponding to vacancies of the one or more computing resources and a semaphore queue of waiting resource requests from the one or more worker threads;
decrementing the semaphore counter when allocating any of the one or more computing resources to one of the one or more worker threads;
incrementing the semaphore counter when releasing any of the one or more computing resources from one of the one or more worker threads;
incrementing the semaphore counter from the one or more worker threads if a request for resource access occurs when the semaphore counter is zero or less than zero; and
decrementing the semaphore counter when receiving a force decrement command from a control thread for reducing a number of computing resources allocable to the one or more worker threads, wherein the semaphore counter will decrease to a negative integer value if the semaphore counter is zero or less than zero at a time of the force decrement command.
8. The method of claim 7 wherein upon decreasing the semaphore counter to a negative integer value, one of the one or more computing resources is deallocated for use by the one or more worker threads prior to any reallocation of the one of the one or more computing resources to the one or more worker threads.
9. The method of claim 7 wherein the one or more computing resources are dedicated to processing data storage requests from the one or more worker threads and the semaphore counter indicates a count of concurrently available data storage segments available for the one or more worker threads.
10. The method of claim 7 wherein the semaphore queue corresponds to a number of resources that need to be requested prior to processing the resource requests of the one or more worker threads.
11. The method of claim 7 wherein the one or more computing resources are dedicated to writing data from cache memory, the one or more worker threads are destagers, and the semaphore counter represents a destager queue size that triggers a release of threads waiting in the semaphore queue.
12. The method of claim 11 wherein upon the semaphore receiving and processing the force decrement command between a time that any of the one or more worker threads decrements the semaphore counter and before the worker thread removes an entry from a working queue, the semaphore counter will be incremented to correct for a double decrement.
13. A computer program product for sharing computing resources, the computer program product comprising a non-transitory computer-readable storage medium encoded with computer-executable program code programmed to cause the execution across one or more processors of:
providing a semaphore for controlling concurrent access to one or more computing resources by one or more worker threads, the semaphore comprising a semaphore counter corresponding to vacancies of the one or more computing resources and a semaphore queue of waiting resource requests from the one or more worker threads;
decrementing the semaphore counter when allocating any of the one or more computing resources to one of the one or more worker threads;
incrementing the semaphore counter when releasing any of the one or more computing resources from one of the one or more worker threads;
incrementing the semaphore counter if a request for resource access occurs when the semaphore counter is zero or less than zero; and
decrementing the semaphore counter when receiving a force decrement command from a control thread for reducing a number of computing resources allocable to the one or more worker threads, wherein the semaphore counter will decrease to a negative integer value if the semaphore counter is zero or less than zero at a time of the force decrement command.