公开(公告)号：US09588822B1

公开(公告)日：2017-03-07

申请号：US13764716

申请日：2013-02-11

Applicant: Amazon Technologies, Inc.

Inventor： Kathryn Marie Shih ,  Eider Brantly Moore ,  Lorenzo Minore ,  Carl Louis Christofferson ,  Richard Rex McKnight ,  Richard Jeffrey Cole ,  Vaibhav Aggarwal ,  Peter Sirota ,  James P. Bartlett

IPC: G06F9/46 ,  G06F9/52

CPC classification number: G06F9/52 ,  G06F9/542 ,  G06Q10/063

Abstract: Methods and systems for using a scheduler in a data pipeline are disclosed. A plurality of objects in a first layer are created, each representing a respective regularly scheduled task. A plurality of objects in a second layer are created, each representing a respective scheduled instance of a regularly scheduled task. It is determined whether each object in the second layer is ready to execute. For at least one object in the second layer, it is determined if the object has received notifications from any objects on which it depends. For each object that is ready to execute, the regularly scheduled task associated with the object is performed. For each object that is not ready to execute, the object is put to sleep.

Abstract translation: 公开了在数据流水线中使用调度器的方法和系统。 创建第一层中的多个对象，每个对象表示相应的规则排列任务。 创建第二层中的多个对象，每个对象表示规则调度任务的相应调度实例。 确定第二层中的每个对象是否准备好执行。 对于第二层中的至少一个对象，确定对象是否已经从其所依赖的任何对象接收到通知。 对于准备执行的每个对象，执行与对象相关联的定期计划的任务。 对于尚未准备好执行的每个对象，对象都将进入休眠状态。