Parallel.For

Just thinking out loud:

function TfrmParallelForDemo.ParaScan(rootNode: TNode; value: integer): TNode;
var
  nodeResult: TNode;
  nodeQueue : TOmniBlockingCollection;
begin
  nodeResult := nil;
  nodeQueue := TOmniBlockingCollection.Create;
  try
    nodeQueue.Add(rootNode);
    Parallel.ForEach(nodeQueue.GetEnumerator).Timeout(10*1000).Execute(
      procedure (const elem: TOmniValue)
      var
        node : TNode;
        iNode: integer;
      begin
        node := TNode(elem.AsPointer);
        if node.Value = value then begin
          nodeResult := node;
          nodeQueue.CompleteAdding;
        end
        else for iNode := 0 to node.NumChild - 1 do
          nodeQueue.TryAdd(node.Child[iNode]);
      end);
  finally FreeAndNil(nodeQueue); end;
  Result := nodeResult;
end; { TfrmParallelForDemo.ParaScan }

I can make it compile (just did) and I think I can make it work.

Useful? Simple enough? What do you think?

---
Published under the Creative Commons Attribution 3.0 license