Engine for reactive execution of massively concurrent heterogeneous accelerated scripted streaming analyses

One or more non-transitory computer-readable media storing instructions that, when executed by one or more processors, cause:

• associating each software actor of a plurality of software actors with one or more data streams, wherein said each software actor comprises a respective backlog queue;
• responsive to receiving content in a subset of said one or more data streams, distributing data based on said content to a subset of software actors of the plurality of software actors that are associated with said subset of said one or more data streams;
• in response to determining that said data satisfies completeness criteria of a particular software actor of said subset of software actors, appending an indication of said data onto said backlog queue of said particular software actor;
• resetting, to an initial state, said particular software actor by loading, into computer memory, an execution snapshot of a previous initial execution of an embedded virtual machine;
• resuming, based on said particular software actor, execution of said execution snapshot of said previous initial execution to dequeue and process said indication of said data from said backlog queue of the particular software actor to generate a result.