Last thread lock management for multi-threaded process and distributed data systems

• US 7,565,406 B2
• Filed: 07/24/2002
• Issued: 07/21/2009
• Est. Priority Date: 07/24/2002
• Status: Active Grant

• Current Assignee: Oracle America, Inc. (Oracle Corporation)
• Original Assignee: Sun Microsystems Incorporated (Oracle Corporation)
• Inventors: E, Sandhya, Kumar, Ajay, Susarla, Hanumantha Rao
• Primary Examiner(s): Etienne; Ario
• Assistant Examiner(s): NASH, LASHANYA RENEE
• Application Number:
  US10/201,844
• Publication Number:
  US 20040019639A1
• Time in Patent Office: 2,554 Days
• Field of Search: 709217-219, 709/210, 709/226, 709/229, 709/205, 709213-215, 709/8, 709/206, 707/10, 707/8, 707/206, 707/216
• US Class Current: 709/215
• CPC Class Codes: G06F 2209/522 Manager
• CPC Class Codes: G06F 9/526 Mutual exclusion algorithms
• CPC Class Codes: H04L 67/02 based on web technology, e.g. hypertext transfer protocol [HTTP]
• CPC Class Codes: H04L 67/14 Session management for real-time applications in data packet communications networks H04L65/1066
• CPC Class Codes: H04L 67/142 Managing session states for stateless protocols; Signalling session states; State transitions; Keeping-state mechanisms
• CPC Class Codes: H04L 69/329 in the application layer [OSI layer 7]
• CPC Class Codes: Y10S 707/99938 Concurrency, e.g. lock management in shared database

Abstract

A distributed data system may include nodes hosting at least one multi-threaded process operable to access portions of distributed data. A lock mechanism may grant locks to multi-threaded processes for portions of the distributed data. Only a process holding a lock may access a portion corresponding to the lock. Threads of other processes may not access the portion. A process may include one or more threads that may acquire a locks for the distributed data portion on behalf of the process. In one embodiment, the lock mechanism may allow any thread of a process release a lock held by the process. In embodiments, the last thread to access the distributed data portion corresponding to the lock may release the lock in response to no more threads of the process require access to the distributed data portion and/or in response to a request to release the lock.

Claims

1. A distributed data system, comprising:

a plurality of network nodes each configured to execute one or more multi-threaded processes comprising a plurality of threads;

a data store configured to store primary data accessible by the multi-threaded processes; and

a lock mechanism coupled to the data store and configured to lock access to portions of the primary data, wherein the lock mechanism is configured to grant a lock to a requester for one of the multi-threaded processes for a primary data portion stored by the data store, wherein the lock mechanism is configured to prevent other processes from accessing the primary data portion while the requester is granted the lock;

wherein each of the multi-threaded processes executing on the plurality of network nodes is configured to have a particular thread of the multi-threaded process request a lock for the portion of the primary data from the lock mechanism, wherein the multi-threaded process is configured to retain the lock while one or more other threads of the multi-threaded process requesting access to the locked portion of primary data access the locked portion of the primary data, and wherein the last thread among the one or more other threads to access the locked portion of primary data is configured to release the lock in response to a determination that no further requests for access to the locked portion of primary data from other threads of the multi-threaded process are pending, wherein said one or more other threads of the multi-threaded process are different than said particular thread of the multi-threaded process.

2. The distributed data system as recited in claim 1, wherein each of the multi-threaded processes is configured such that when the particular thread of the multi-threaded process that requested the lock acquires the lock, the one or more other threads of the multi-threaded process requesting access to the portion of the primary data access the portion of the primary data while the multi-threaded process retains the lock.

3. The distributed data system as recited in claim 2, wherein each of the multi-threaded processes is configured to:

increment a count corresponding to the lock for the portion of the primary data in response to a thread of the multi-threaded process requesting access to the portion of the primary data;

decrement the count in response to a thread completing access to the locked portion of the primary data; and

wherein the last thread is configured to release the lock in response to the count reaching an initial value.

4. The distributed data system as recited in claim 1, wherein each of the multi-threaded processes is configured to initiate a dummy requester upon acquiring the lock to indicate a pending request for access to the portion of the primary data, wherein the multi-threaded process is configured to cancel the dummy requester only in response to receiving a request to release the lock so that the multi-threaded process holds the lock until the multi-threaded process receives a request to release the lock.

5. The distributed data system as recited in claim 1, wherein the plurality of network nodes comprise one or more application servers of a multi-tiered enterprise system.

6. The distributed data system as recited in claim 1, wherein the one of the multi-threaded processes comprises a Java virtual machine.

7. The distributed data system as recited in claim 1, wherein a portion of the primary data stored by the data store represents state information of a client-server session.

8. The distributed data system as recited in claim 1, wherein if a requester for a process holds a lock for a portion of the primary data, the lock mechanism is configured to buffer one or more requests for the lock for that portion of the primary data from one or more other requesters for one or more other processes.

9. The distributed data system as recited in claim 8, wherein in response to the last thread releasing the lock for the portion of the primary data, the lock mechanism is configured to grant the lock for that portion of the primary data to a next buffered requester for that primary data portion.

10. A computing system, comprising:

a processor;

memory comprising program instructions executable by the processor to implement;

a multi-threaded process comprising a plurality of threads, the multi-threaded process configured to access portions of distributed data stored within a distributed data store accessible to other processes;

wherein the multi-threaded process is configured to have a particular thread of the multi-threaded process request a lock for a portion of the distributed data from a lock mechanism of the distributed data store, wherein the multi-threaded process is configured to retain the lock while one or more other threads of the multi-threaded process requesting access to the locked portion of distributed data access the locked portion of the distributed data, and wherein the last thread among the one or more other threads to access the locked portion of distributed data is configured to release the lock in response to a determination that no further requests for access to the locked portion of distributed data from other threads of the multi-threaded process are pending, wherein said one or more other threads of the multi-threaded process are different than said particular thread of the multi-threaded process.

11. The computing system as recited in claim 10, wherein the multi-threaded process is configured so that when the thread that requested the lock obtains the lock for the portion of the distributed data the one or more other threads access the portion of the distributed data while the multi-threaded process retains the lock.

12. The computing system as recited in claim 11, wherein the multi-threaded process is configured to:

increment a count corresponding to the lock for the portion of the distributed data in response to a thread of the multi-threaded process requesting access to the portion of the distributed data;

decrement the count in response to a thread of the multi-threaded process completing access to the locked portion of the distributed data; and

wherein the last thread is configured to release the lock in response to the count reaching an initial value.

13. The computing system as recited in claim 10, wherein the multi-threaded process is configured to initiate a dummy requester upon acquiring the lock to indicate a pending request for access to the portion of the distributed data, wherein the multi-threaded process is configured to cancel the dummy requester only in response to receiving a request to release the lock so that the multi-threaded process holds the lock until the multi-threaded process receives a request to release the lock.

14. The computing system as recited in claim 10, wherein the memory comprises program instructions executable by the processor to implement an application server for a multi-tiered enterprise system, wherein the multi-threaded process is configured to execute within the application server.

15. The computing system as recited in claim 10, wherein the multi-threaded process comprises a Java virtual machine.

16. The computing system as recited in claim 10, wherein a portion of the distributed data represents state information of a client-server session.

17. A method, comprising:

a particular thread of a multi-threaded process acquiring a lock for a portion of distributed data of a distributed data store from a lock mechanism of the distributed data store, wherein said multi-threaded process comprises a plurality of threads;

one or more other threads of the multi-threaded process requesting access to the locked portion of the distributed data while the multi-threaded process retains the lock, wherein said one or more other threads of the multi-threaded process are different than said particular thread of the multi-threaded process; and

a last thread of said one or more other threads to request access to the portion of the distributed data releasing the lock in response to a determination that no further requests for access to the locked portion of distributed data from other threads of the multi-threaded process are pending.

18. The method as recited in claim 17, further comprising the one or more other threads of the multi-threaded process accessing the portion of the distributed data while the multi-threaded process retains the lock.

19. The method as recited in claim 18, further comprising:

incrementing a count corresponding to the portion of the distributed data for each thread of the multi-threaded process requesting access to the portion of the distributed data;

decrementing the count corresponding to the locked portion of the distributed data for each thread of the multi-threaded process completing access to the locked portion of the distributed data; and

the last thread releasing the lock for the multi-threaded process in response to the count reaching an initial value.

20. The method as recited in claim 17, further comprising:

the multi-threaded process initiating a dummy requester upon acquiring the lock to indicate a pending request for access to the portion of the distributed data; and

if the multi-threaded process is requested to release the lock, the multi-threaded process canceling the dummy requester so that the multi-threaded process holds the lock until the multi-threaded process receives a request to release the lock.

21. The method as recited in claim 17, further comprising another thread of the multi-threaded process releasing the lock for the multi-threaded process when further requests are pending.

22. A computer-accessible storage medium, storing program instructions executable to implement:

a particular thread of a multi-threaded process acquiring a lock for a portion of distributed data of a distributed data store from a lock mechanism of the distributed data store, wherein said multi-threaded process comprises a plurality of threads;

one or more other threads of the multi-threaded process requesting access to the locked portion of the distributed data while the multi-threaded process retains the lock, wherein said one or more other threads of the multi-threaded process are different than said particular thread of the multi-threaded process; and

a last thread of said one or more other threads to request access to the portion of the distributed data releasing the lock in response to a determination that no further requests for access to the locked portion of distributed data from other threads of the multi-threaded process are pending.

23. The computer-accessible storage medium as recited in claim 22, wherein the program instructions are further executable to implement the one or more other threads of the multi-threaded process accessing the portion of the distributed data while the multi-threaded process retains the lock.

24. The computer-accessible storage medium as recited in claim 23, wherein the program instructions are fuarther executable to implement:

incrementing a count corresponding to the portion of the distributed data for each thread of the multi-threaded process requesting access to the portion of the distributed data;

decrementing the count corresponding to the locked portion of the distributed data for each thread of the multi-threaded process completing access to the locked portion of the distributed data; and

the last thread releasing the lock for the multi-threaded process in response to the count reaching an initial value.

25. The computer-accessible storage medium as recited in claim 22, wherein the program instructions are further executable to implement:

the multi-threaded process initiating a dummy requester upon acquiring the lock to indicate a pending request for access to the portion of the distributed data; and

if the multi-threaded process is requested to release the lock, the multi-threaded process canceling the dummy requester so that the multi-threaded process holds the lock until the multi-threaded process receives a request to release the lock.

26. The computer-accessible storage medium as recited in claim 22, wherein the program instructions are further executable to implement another thread of the multi-threaded process releasing the lock for the process when further requests are pending.