System and method for transforming a queue from non-blocking to blocking

• US 10,095,562 B2
• Filed: 02/28/2013
• Issued: 10/09/2018
• Est. Priority Date: 02/28/2013
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Otenko, Oleksandr
• Primary Examiner(s): Dascomb, Jacob D
• Application Number:
  US13/781,500
• Publication Number:
  US 20140245309A1
• Time in Patent Office: 2,049 Days
• CPC Class Codes: G06F 2209/548 Queue
• CPC Class Codes: G06F 9/546 Message passing systems or structures, e.g. queues

Abstract

A system and method can use continuation-passing to transform a queue from non-blocking to blocking. The non-blocking queue can maintain one or more idle workers in a thread pool that is not accessible from outside of the non-blocking queue. The continuation-passing can eliminate one or more serialization points in the non-blocking queue, and allows a caller to manage the one or more idle workers in the thread pool from outside of the non-blocking queue.

Claims

1. A method for transforming a queue from non-blocking to blocking, comprising:

instantiating a callable object, the callable object having at least one function that can be called;

providing a non-blocking queue into which requests are placed for processing;

providing a function of the non-blocking queue that accepts a first parameter and a second parameter;

associating a thread pool with the non-blocking queue, wherein the thread pool contains one or more threads that process the requests placed in the non-blocking queue, and wherein the thread pool is accessible from the non-blocking queue;

calling the function of the non-blocking queue from a request manager;

including, by the request manager, a caller request as the first parameter of the function of the non-blocking queue, and the instantiated callable object as the second parameter of the non-blocking queue;

determining, by the function of the non-blocking queue, that the non-blocking queue is available to process the caller request;

calling, by the function of the non-blocking queue, the at least one function of the callable object;

polling, by the at least one function of the callable object, a thread from the thread pool;

returning, by the at least one function of the callable object, the polled thread to the function of the non-blocking queue;

returning, by the function of the non-blocking queue, the polled thread to the request manager; and

using the polled thread within the thread pool, to process the caller request.

2. The method according to claim 1, further comprising:

associating, by the at least one function of the callable object, the polled thread with the caller request.

3. The method according to claim 1, wherein the function of the non-blocking queue is an add( ) function.

4. The method according to claim 1, wherein the class of the callable object implements an interface, and wherein the interface defines the at least one function of the callable object.

5. The method according to claim 1, further comprising:

the request manager allowing a plurality of callers to access the non-blocking queue concurrently via the function of the non-blocking queue.

6. The method according to claim 1, wherein the thread pool is not accessible from outside of the non-blocking queue.

7. The method according to claim 1, wherein the request manager calls the function of the non-blocking queue via an interface provided by the non-blocking queue.

8. The method according to claim 1, wherein the determining that the non-blocking queue is available to process the request includes determining that the non-blocking queue is empty.

9. The method according to claim 1, further comprising when the non-blocking queue is not empty, returning a null value to the request manager.

10. A system for transforming a queue from non-blocking to blocking, comprising:

one or more microprocessors;

a non-blocking queue into which requests can be placed for processing, and that exposes a function of the non-blocking queue that accepts a first parameter and a second parameter;

a thread pool that is associated with the non-blocking queue, wherein the thread pool contains one or more threads that process the requests placed in the non-blocking queue, and wherein the thread pool is accessible from the non-blocking queue;

wherein the system, running on the one or more microprocessors, operates to;

instantiate a callable object, the callable object having at least one function that can be called;

call the function of the non-blocking queue from a request manager, wherein the request manager includes a caller request as the first parameter of the function of the non-blocking queue, and the instantiated callable object as the second parameter of the non-blocking queue;

determine, via the function of the non-blocking queue, that the non-blocking queue is available to process the caller request;

call, via the function of the non-blocking queue, the at least one function of the callable object;

poll, via the at least one function of the callable object, a thread from the thread pool;

return, via the at least one function of the callable object, the polled thread to the function of the non-blocking queue;

return, by the function of the non-blocking queue, the polled thread to the request manager;

and

use the polled thread within the thread pool, to process the caller request.

11. The system according to claim 10, wherein the system further operates to associate, via the at least one function of the callable object, the polled thread with the caller request.

12. The system according to claim 10, wherein the function of the non-blocking queue is an add( ) function.

13. The system according to claim 10, wherein the class of the callable object implements an interface, and wherein the interface defines the at least one function of the callable object.

14. The system according to claim 10, wherein the thread pool is not accessible from outside of the non-blocking queue.

15. The system according to claim 10, wherein the request manager calls the function of the non-blocking queue via an interface provided by the non-blocking queue.

16. The system according to claim 10, wherein determination that the non-blocking queue is available to process the request includes determining that the non-blocking queue is empty.

17. The system according to claim 10, wherein when the non-blocking queue is not empty, returning a null value to the request manager.

18. A non-transitory machine readable storage medium having instructions stored thereon that when executed cause a system to transform a queue from non-blocking to blocking, by performing a method comprising:

instantiating a callable object, the callable object having at least one function that can be called;

providing a non-blocking queue into which requests are placed for processing;

providing a function of the non-blocking queue that accepts a first parameter and a second parameter;

associating a thread pool with the non-blocking queue, wherein the thread pool contains one or more threads that process the requests placed in the non-blocking queue, and wherein the thread pool is accessible from the non-blocking queue;

calling the function of the non-blocking queue from a request manager;

including, by the request manager, a caller request as the first parameter of the function of the non-blocking queue, and the instantiated callable object as the second parameter of the non-blocking queue;

determining, by the function of the non-blocking queue, that the non-blocking queue is empty;

calling, by the function of the non-blocking queue, the at least one function of the callable object;

polling, by the at least one function of the callable object, a thread from the thread pool;

associating, by the at least one function of the callable object, the polled thread with the caller request;

returning, by the at least one function of the callable object, the polled thread to the function of the non-blocking queue;

returning, by the function of the non-blocking queue, the polled thread to the request manager;

and

using the polled thread within the thread pool, to process the caller request.