Systems and methods for implementing and using a cross-process queue within a single computer
A system, method, and computer-program product includes implementing a cross-process queue within a single computer that is configured to transfer a data block between an operating system process executing a write operation and an operating system process executing a read operation, initializing in-memory cell indices within the cross-process queue that include a write operation index tracking index values of one or more cells within the cross-process queue that are available to write and a read operation index tracking index values of one or more cells within the cross-process queue that are available to read, and implementing a cell synchronization data structure tracking states of a plurality of cells of the index of cells of the cross-process queue.
1. A computer-program product embodied in a non-transitory machine-readable storage medium storing computer instructions that, when executed by one or more processors, perform operations comprising:
implementing a cross-process queue within a single computer that enables a transfer of data between a first operating system process and a second operating system process, wherein:
the first operating system process is created by executing a computer program written in a first computer language, and the second operating system process is created by executing a computer program written in a second computer language;
receiving, at the cross-process queue, a data block from the first operating system process based on an execution by the first operating system process of a write operation to a memory of the cross-process queue, wherein the data block is encoded in a data structure of the first computer language;
implementing a cell synchronization data structure tracking states of a plurality of cells of index of cells of the cross-process queue, wherein the cell synchronization data structure counts cells of the plurality of cells of the index of cells to determine available cells for the write operation and the read operation;
regulating a utilization of the cross-process queue for the first or second operating system process executing the write operation and read operation based on the count of cells of the index of cells that are available for the write operation and the read operation;
converting, by an interpreting application, the data block encoded in the data structure of the first computer language to a translated data block encoded in a data structure of the second computer language;
storing, within the memory of the cross-process queue, the translated data block based on the conversion of the data block; and
enabling a read access, by the second operating system process, to the translated data block stored within the memory of the cross-process queue.
2. The computer-program product according to claim 1 , wherein converting, by the interpreting application, the data block encoded in the data structure of the first computer language includes:
automatically converting one or more data types of the first computer language to one or more data types of the second computer language based on the receiving, at the cross-process queue, the data block from the first operating system process.
3. The computer-program product according to claim 1 , wherein converting, by the interpreting application, the data block encoded in the data structure of the first computer language includes:
automatically converting one or more objects of the first computer language to one or more objects of the second computer language based on the receiving, at the cross-process queue, the data block from the first operating system process.
4. The computer-program product according to claim 1 , wherein the first operating system process based on identifying the second computer language of the second operating system process, automatically connects to the interpreting application enabling the conversion of the data block during the write operation by the first operating system process to the memory of the cross-process queue.
5. The computer-program product according to claim 1 , wherein the interpreting application is implemented as a child process of the first operating system process.
6. The computer-program product according to claim 5 , wherein the interpreting application is extensible to interpreting a given data block encoded in the data structure of the first computer language to a target computer language of a plurality of computer languages based on identifying a computer language of a given operating system process that executes read operations in the target computer language.
7. The computer-program product according to claim 1 , wherein the memory of the cross-process queue comprises:
a plurality of cells of fixed length that are available for writing data to and available for reading from by each of the first operating system process and the second operating system process.
8. The computer-program product according to claim 7 , wherein data stored within each of the plurality of cells of the memory channel is encoded with a respective type safety header identifying a respective data type of a plurality of data types of an item of data stored within a respective cell of the plurality of cells.
9. The computer-program product according to claim 8 , wherein a given type safety header a given cell of the plurality of cells prohibits an attempted read operation of a given item of data stored within the given cell when the attempted read operation executes a read operation in a different data type than a data type identified by the given type safety header.
10. The computer-program product according to claim 8 , further comprising:
detecting an attempted read operation of a given data stored within a given cell of the plurality of cells when the attempted read operation executes a read operation in a different data type than a given data type identified by the type safety header;
generating a read exception based on the detection of the attempted read operation; and
automatically transforming the given data type of the type safety header of the given data to the different data type based on the read exception.
11. A computer-implemented method comprising:
implementing a cross-process queue within a single computer that enables a transfer of data between a first operating system process and a second operating system process, wherein:
the first operating system process is created by executing a computer program written in a first computer language, and the second operating system process is created by executing a computer program written in a second computer language;
receiving, at the cross-process queue, a data block from the first operating system process based on an execution by the first operating system process of a write operation to a memory of the cross-process queue, wherein the data block is encoded in a data structure of the first computer language;
implementing a cell synchronization data structure tracking states of a plurality of cells of index of cells of the cross-process queue, wherein the cell synchronization data structure counts cells of the plurality of cells of the index of cells to determine available cells for the write operation and the read operation;
regulating a utilization of the cross-process queue for the first or second operating system process executing the write operation and read operation based on the count of cells of the index of cells that are available for the write operation and the read operation;
converting, by an interpreting application, the data block encoded in the data structure of the first computer language to a translated data block encoded in a data structure of the second computer language;
storing, within the memory of the cross-process queue, the translated data block based on the conversion of the data block; and
enabling a read access, by the second operating system process, to the translated data block stored within the memory of the cross-process queue.
12. The computer-implemented method according to claim 11 , wherein converting, by the interpreting application, the data block encoded in the data structure of the first computer language includes:
automatically converting one or more data types of the first computer language to one or more data types of the second computer language based on the receiving, at the cross-process queue, the data block from the first operating system process.
13. The computer-implemented method according to claim 11 , wherein converting, by the interpreting application, the data block encoded in the data structure of the first computer language includes:
automatically converting one or more objects of the first computer language to one or more objects of the second computer language based on the receiving, at the cross-process queue, the data block from the first operating system process.
14. The computer-implemented method according to claim 11 , wherein the first operating system process based on identifying the second computer language of the second operating system process, automatically connects to the interpreting application enabling the conversion of the data block during the write operation by the first operating system process to the memory of the cross-process queue.
15. The computer-implemented method according to claim 11 , wherein the interpreting application is implemented as a child process of the first operating system process.
16. The computer-implemented method according to claim 15 , wherein the interpreting application is extensible to interpreting a given data block encoded in the data structure of the first computer language to a target computer language of a plurality of computer languages based on identifying a computer language of a given operating system process that executes read operations in the target computer language.
17. The computer-implemented method according to claim 11 , wherein the memory of the cross-process queue comprises:
a plurality of cells of fixed length that are available for writing data to and available for reading from by each of the first operating system process and the second operating system process.
18. The computer-implemented method according to claim 17 , wherein data stored within each of the plurality of cells of the memory channel is encoded with a respective type safety header identifying a respective data type of a plurality of data types of an item of data stored within a respective cell of the plurality of cells.
19. The computer-implemented method according to claim 18 , wherein a given type safety header a given cell of the plurality of cells prohibits an attempted read operation of a given item of data stored within the given cell when the attempted read operation executes a read operation in a different data type than a data type identified by the given type safety header.
20. The computer-implemented method according to claim 18 , further comprising:
detecting an attempted read operation of a given data stored within a given cell of the plurality of cells when the attempted read operation executes a read operation in a different data type than a given data type identified by the type safety header;
generating a read exception based on the detection of the attempted read operation; and
automatically transforming the given data type of the type safety header of the given data to the different data type based on the read exception.
21. A computer-implemented system comprising:
one or more processors;
a memory;
a computer-readable medium operably coupled to the one or more processors, the computer-readable medium having computer-readable instructions stored thereon that, when executed by the one or more processors, cause a computing device to perform operations comprising:
implementing a cross-process queue within a single computer that enables a transfer of data between a first operating system process and a second operating system process, wherein:
the first operating system process is created by executing a computer program written in a first computer language, and the second operating system process is created by executing a computer program written in a second computer language;
receiving, at the cross-process queue, a data block from the first operating system process based on an execution by the first operating system process of a write operation to a memory of the cross-process queue, wherein the data block is encoded in a data structure of the first computer language;
implementing a cell synchronization data structure tracking states of a plurality of cells of index of cells of the cross-process queue, wherein the cell synchronization data structure counts cells of the plurality of cells of the index of cells to determine available cells for the write operation and the read operation;
regulating a utilization of the cross-process queue for the first or second operating system process executing the write operation and read operation based on the count of cells of the index of cells that are available for the write operation and the read operation;
converting, by an interpreting application, the data block encoded in the data structure of the first computer language to a translated data block encoded in a data structure of the second computer language;
storing, within the memory of the cross-process queue, the translated data block based on the conversion of the data block; and
enabling a read access, by the second operating system process, to the translated data block stored within the memory of the cross-process queue.
22. The computer-implemented system according to claim 21 , wherein converting, by the interpreting application, the data block encoded in the data structure of the first computer language includes:
automatically converting one or more data types of the first computer language to one or more data types of the second computer language based on the receiving, at the cross-process queue, the data block from the first operating system process.
23. The computer-implemented system according to claim 21 , wherein converting, by the interpreting application, the data block encoded in the data structure of the first computer language includes:
automatically converting one or more objects of the first computer language to one or more objects of the second computer language based on the receiving, at the cross-process queue, the data block from the first operating system process.
24. The computer-implemented system according to claim 21 , wherein the first operating system process based on identifying the second computer language of the second operating system process, automatically connects to the interpreting application enabling the conversion of the data block during the write operation by the first operating system process to the memory of the cross-process queue.
25. The computer-implemented system according to claim 21 , wherein the interpreting application is implemented as a child process of the first operating system process.
26. The computer-implemented system according to claim 25 , wherein the interpreting application is extensible to interpreting a given data block encoded in the data structure of the first computer language to a target computer language of a plurality of computer languages based on identifying a computer language of a given operating system process that executes read operations in the target computer language.
27. The computer-implemented system according to claim 21 , wherein the memory of the cross-process queue comprises:
a plurality of cells of fixed length that are available for writing data to and available for reading from by each of the first operating system process and the second operating system process.
28. The computer-implemented system according to claim 27 , wherein data stored within each of the plurality of cells of the memory channel is encoded with a respective type safety header identifying a respective data type of a plurality of data types of an item of data stored within a respective cell of the plurality of cells.
29. The computer-implemented system according to claim 28 , wherein a given type safety header a given cell of the plurality of cells prohibits an attempted read operation of a given item of data stored within the given cell when the attempted read operation executes a read operation in a different data type than a data type identified by the given type safety header.
30. The computer-implemented system according to claim 28 , further comprising:
detecting an attempted read operation of a given data stored within a given cell of the plurality of cells when the attempted read operation executes a read operation in a different data type than a given data type identified by the type safety header;
generating a read exception based on the detection of the attempted read operation; and
automatically transforming the given data type of the type safety header of the given data to the different data type based on the read exception.