公开(公告)号：US20110231861A1

公开(公告)日：2011-09-22

申请号：US12727689

申请日：2010-03-19

申请人： Mike Liddell ,  John Duffy

发明人： Mike Liddell ,  John Duffy

IPC分类号： G06F9/44

CPC分类号： G06F9/485

摘要： A method of performing a cancellation of concurrent worker objects includes creating a plurality of concurrent worker objects with a manager object. At least one cancellation object is generated with the manager object. The at least one cancellation object includes a cancel method and a register method that support concurrent calls. A callback function is registered by calling the register method with one of the concurrent worker objects. A cancellation of the concurrent worker objects is requested by calling the cancel method with the manager object.

摘要翻译： 执行并发工作对象的取消的方法包括使用管理对象创建多个并发工作对象。 使用管理对象生成至少一个取消对象。 所述至少一个取消对象包括支持并发呼叫的取消方法和注册方法。 通过使用并发工作对象之一调用寄存器方法来注册回调函数。 通过使用管理对象调用cancel方法来请求并发工作对象的取消。

公开(公告)号：US09229788B2

公开(公告)日：2016-01-05

申请号：US12732552

申请日：2010-03-26

申请人： Stephen H. Toub ,  Joseph E. Hoag ,  Huseyin S. Yildiz ,  Danny S. Shih ,  Mike Liddell ,  John Duffy

发明人： Stephen H. Toub ,  Joseph E. Hoag ,  Huseyin S. Yildiz ,  Danny S. Shih ,  Mike Liddell ,  John Duffy

IPC分类号： G06F9/46 ,  G06F9/52

CPC分类号： G06F9/522

摘要： A method of performing a wait operation includes creating a first plurality of tasks and a continuation task. The continuation task represents a second plurality of tasks. The continuation task and each of the tasks in the first plurality have an associated wait handle. The wait handles for the first plurality of tasks and the continuation task are stored in an array. A wait operation is performed on the array, thereby waiting for at least one of the tasks in the first and second pluralities to complete.

摘要翻译： 执行等待操作的方法包括创建第一多个任务和连续任务。 继续任务表示第二个多个任务。 继续任务和第一组中的每个任务具有相关联的等待句柄。 第一个多任务和连续任务的等待句柄存储在一个数组中。 在阵列上执行等待操作，从而等待第一和第二多个中的至少一个任务完成。

公开(公告)号：US20110239217A1

公开(公告)日：2011-09-29

申请号：US12732552

申请日：2010-03-26

申请人： Stephen H. Toub ,  Joseph E. Hoag ,  Huseyin S. Yildiz ,  Danny S. Shih ,  Mike Liddell ,  John Duffy

发明人： Stephen H. Toub ,  Joseph E. Hoag ,  Huseyin S. Yildiz ,  Danny S. Shih ,  Mike Liddell ,  John Duffy

IPC分类号： G06F9/46

CPC分类号： G06F9/522

摘要： A method of performing a wait operation includes creating a first plurality of tasks and a continuation task. The continuation task represents a second plurality of tasks. The continuation task and each of the tasks in the first plurality have an associated wait handle. The wait handles for the first plurality of tasks and the continuation task are stored in an array. A wait operation is performed on the array, thereby waiting for at least one of the tasks in the first and second pluralities to complete.

摘要翻译： 执行等待操作的方法包括创建第一多个任务和连续任务。 继续任务表示第二个多个任务。 继续任务和第一组中的每个任务具有相关联的等待句柄。 第一个多任务和连续任务的等待句柄存储在一个数组中。 在阵列上执行等待操作，从而等待第一和第二多个中的至少一个任务完成。

公开(公告)号：US20100185840A1

公开(公告)日：2010-07-22

申请号：US12357850

申请日：2009-01-22

申请人： John Duffy ,  Stephen H. Toub ,  Huseyin S. Yildiz ,  Mike Liddell

发明人： John Duffy ,  Stephen H. Toub ,  Huseyin S. Yildiz ,  Mike Liddell

IPC分类号： G06F9/38

CPC分类号： G06F9/3865 ,  G06F9/4488 ,  G06F9/4812 ,  G06F11/1402 ,  G06F2209/481

摘要： A method of handling an exception in a parallel system includes constructing a task object, executing a method with the task object, and catching an exception with the task object during execution of the method. The exception is propagated in response to the task object becoming inaccessible without the exception having been observed.

摘要翻译： 在并行系统中处理异常的方法包括：在执行该方法期间，构建一个任务对象，执行一个具有该任务对象的方法，以及在该任务对象中捕获一个异常。 异常被传播以响应任务对象变得无法访问，而没有被观察到例外。

公开(公告)号：US08996556B2

公开(公告)日：2015-03-31

申请号：US12479242

申请日：2009-06-05

申请人： Igor Ostrovsky ,  John Duffy ,  Mike Liddell

发明人： Igor Ostrovsky ,  John Duffy ,  Mike Liddell

IPC分类号： G06F17/30

CPC分类号： G06F17/30516 ,  G06F17/30224

摘要： A method of parallel processing an ordered input data stream that includes a plurality of input data elements and a corresponding plurality of order keys for indicating an ordering of the input data elements, with each order key associated with one of the input data elements, includes processing the input data stream in a parallel manner with a plurality of worker units, thereby generating a plurality of sets of output data elements. The plurality of sets of output data elements is stored in a plurality of buffers, with each buffer associated with one of the worker units. An ordered output data stream is output while the input data stream is being processed by outputting selected output data elements from the buffers in an order that is based on the order keys.

摘要翻译： 一种并行处理有序输入数据流的方法，包括多个输入数据元素和相应的多个顺序密钥，用于指示输入数据元素的排序，其中每个订单密钥与输入数据元素之一相关联，包括处理 所述输入数据流与多个工作单元并行地进行，从而生成多组输出数据元素。 多组输出数据元素被存储在多个缓冲器中，每个缓冲器与其中一个工作单元相关联。 通过以基于订单密钥的顺序从缓冲器输出所选择的输出数据元素，输出数据流被处理时输出有序的输出数据流。

公开(公告)号：US08359604B2

公开(公告)日：2013-01-22

申请号：US12357850

申请日：2009-01-22

申请人： John Duffy ,  Stephen Toub ,  Huseyin Yildiz ,  Mike Liddell

发明人： John Duffy ,  Stephen Toub ,  Huseyin Yildiz ,  Mike Liddell

IPC分类号： G06F3/00

CPC分类号： G06F9/3865 ,  G06F9/4488 ,  G06F9/4812 ,  G06F11/1402 ,  G06F2209/481

摘要： A method of handling an exception in a parallel system includes constructing a task object, executing a method with the task object, and catching an exception with the task object during execution of the method. The exception is propagated in response to the task object becoming inaccessible without the exception having been observed.

摘要翻译： 在并行系统中处理异常的方法包括：在执行该方法期间，构建一个任务对象，执行一个具有该任务对象的方法，以及在该任务对象中捕获一个异常。 异常被传播以响应任务对象变得无法访问，而没有被观察到例外。

公开(公告)号：US08327383B2

公开(公告)日：2012-12-04

申请号：US12727689

申请日：2010-03-19

申请人： Mike Liddell ,  John Duffy

发明人： Mike Liddell ,  John Duffy

IPC分类号： G06F13/00

CPC分类号： G06F9/485

摘要： A method of performing a cancellation of concurrent worker objects includes creating a plurality of concurrent worker objects with a manager object. At least one cancellation object is generated with the manager object. The at least one cancellation object includes a cancel method and a register method that support concurrent calls. A callback function is registered by calling the register method with one of the concurrent worker objects. A cancellation of the concurrent worker objects is requested by calling the cancel method with the manager object.

摘要翻译： 执行并发工作对象的取消的方法包括使用管理对象创建多个并发工作对象。 使用管理对象生成至少一个取消对象。 所述至少一个取消对象包括支持并发呼叫的取消方法和注册方法。 通过使用并发工作对象之一调用寄存器方法来注册回调函数。 通过使用管理对象调用cancel方法来请求并发工作对象的取消。

公开(公告)号：US08266172B2

公开(公告)日：2012-09-11

申请号：US12418136

申请日：2009-04-03

申请人： Igor Ostrovsky ,  John Duffy ,  Mike Liddell ,  Edward G. Essey ,  Stephen H. Toub

发明人： Igor Ostrovsky ,  John Duffy ,  Mike Liddell ,  Edward G. Essey ,  Stephen H. Toub

IPC分类号： G06F7/00

CPC分类号： G06F17/30445

摘要： A method of analyzing a data parallel query includes receiving a user-specified data parallel query that includes a plurality of query operators. An operator type for each of the query operators is identified based on a type of parallel input data structure the operator operates on and a type of parallel output data structure the operator outputs. It is determined whether the query is a prohibited query based on the identified operator types.

摘要翻译： 分析数据并行查询的方法包括接收包括多个查询运算符的用户指定的数据并行查询。 基于操作员操作的并行输入数据结构的类型和操作员输出的并行输出数据结构的类型来识别每个查询运算符的运算符类型。 基于所识别的运算符类型来确定查询是否是禁止查询。

公开(公告)号：US20100312801A1

公开(公告)日：2010-12-09

申请号：US12479242

申请日：2009-06-05

申请人： Igor Ostrovsky ,  John Duffy ,  Mike Liddell

发明人： Igor Ostrovsky ,  John Duffy ,  Mike Liddell

IPC分类号： G06F9/30 ,  G06F17/30

CPC分类号： G06F17/30516 ,  G06F17/30224

摘要： A method of parallel processing an ordered input data stream that includes a plurality of input data elements and a corresponding plurality of order keys for indicating an ordering of the input data elements, with each order key associated with one of the input data elements, includes processing the input data stream in a parallel manner with a plurality of worker units, thereby generating a plurality of sets of output data elements. The plurality of sets of output data elements is stored in a plurality of buffers, with each buffer associated with one of the worker units. An ordered output data stream is output while the input data stream is being processed by outputting selected output data elements from the buffers in an order that is based on the order keys.

摘要翻译： 一种并行处理有序输入数据流的方法，包括多个输入数据元素和相应的多个顺序密钥，用于指示输入数据元素的排序，其中每个订单密钥与输入数据元素之一相关联，包括处理 所述输入数据流与多个工作单元并行地进行，从而生成多组输出数据元素。 多组输出数据元素被存储在多个缓冲器中，每个缓冲器与其中一个工作单元相关联。 通过以基于订单密钥的顺序从缓冲器输出所选择的输出数据元素，输出数据流被处理时输出有序的输出数据流。

公开(公告)号：US20100257191A1

公开(公告)日：2010-10-07

申请号：US12418136

申请日：2009-04-03

申请人： Igor Ostrovsky ,  John Duffy ,  Mike Liddell ,  Edward G. Essey ,  Stephen H. Toub

发明人： Igor Ostrovsky ,  John Duffy ,  Mike Liddell ,  Edward G. Essey ,  Stephen H. Toub

IPC分类号： G06F17/30

CPC分类号： G06F17/30445

摘要： A method of analyzing a data parallel query includes receiving a user-specified data parallel query that includes a plurality of query operators. An operator type for each of the query operators is identified based on a type of parallel input data structure the operator operates on and a type of parallel output data structure the operator outputs. It is determined whether the query is a prohibited query based on the identified operator types.

摘要翻译： 分析数据并行查询的方法包括接收包括多个查询运算符的用户指定的数据并行查询。 基于操作员操作的并行输入数据结构的类型和操作员输出的并行输出数据结构的类型来识别每个查询运算符的运算符类型。 基于所识别的运算符类型来确定查询是否是禁止查询。