Re: Parallelism Map and Reduce

[Ali Çehreli]

On 12/12/2012 05:47 AM, Zardoz wrote:
> On Tuesday, 11 December 2012 at 17:50:31 UTC, Ali Çehreli wrote:
>> On 12/11/2012 08:12 AM, Zardoz wrote:
>>
>>
>> Could you please move MapIntegrator() to module-level. Then it should
>> work.
>>
>> Ali
>
> I try it and now even with normal Map function give me errors with dmd !
>
> public Entity MapIntegrator ( Entity me) {
> me.Integrador3Orden ();
> return me;
> }
>
> void main() {
> Entity[] objects;
> ...
> objects = array( map!MapIntegrator(objects) );
> ...
> }
>
> With this error :
> dmd -w -wi -version=SReduction simulator.d entity.d vector.d -ofreduceSim
> simulator.d(194): Error: template std.algorithm.map!(MapIntegrator).map
> does not match any function template declaration
> /usr/include/dmd/phobos/std/algorithm.d(369): Error: template
> std.algorithm.map!(MapIntegrator).map(Range) if
> (isInputRange!(Unqual!(Range))) cannot deduce template function from
> argument types !()(Entity[])
Strange. The following program works for me with dmd 2.060. It uses both 
the regular and parallel versions of map and reduce:

import std.array;
import std.algorithm;
import std.parallelism;

struct Entity
{
    void Integrador3Orden()
    {}
}

public Entity MapIntegrator ( Entity me) {
  me.Integrador3Orden ();
  return me;
}

void main() {
  Entity[] objects;

  objects = array( map!MapIntegrator(objects) );
  objects = array(taskPool.map!MapIntegrator(objects));

  int[] acelByObjs;
  int reduced = reduce!"a + b"(0, acelByObjs);
  reduced = taskPool.reduce!"a + b"(0, acelByObjs);
}

Ali