Method and system for reconciling concurrent streams of transactions in a database

摘要

A method and system for reconciling in a scheduling database the execution of a high priority stream of transactions that is concurrent with a low priority stream of transactions comprise the steps of copying a portion of the database into a temporary storage, establishing the high priority stream in the database, establishing the low priority stream in the temporary storage, reconciling the low priority stream with the high priority stream, and establishing some or all of the low priority stream of transactions in the database such that the high priority stream has data priority over the low priority stream and the resulting database satisfies certain safety and liveness constraints. Specifically, the reconciliation step further comprises the steps of 1) identifying pinged tasks in the database that are unassigned before the execution of the high priority stream of transactions in the database, 2) identifying the tasks that are assigned to pinged resources in the database, 3) unassigning the tasks in the temporary database that correspond to the identified tasks in the database, 4) assigning to unpinged resources some of the tasks that are unassigned in the temporary storage and that are unpinged in the database, and 5) establishing in the database the resulting assignment relations of the temporary storage.