Re: Retrieve the data of all the threads together once all threads are completed in a task pool

[vino via Digitalmars-d-learn]

On Saturday, 26 August 2017 at 17:38:37 UTC, Vino.B wrote:
Hi,
  Can some one provide me an example of how to wait for all the 
threads to be completed in a taskPool and then retrieve the 
data of all the threads together instead of getting the data of 
each threads(after successfully executed). For example, the 
below test program outputs only one string "Welcome" but not 
the string "Home".

import std.stdio;
import std.parallelism;

string Data;
auto Textarr = [ "Welcome", "Home" ];

string fn (string text)
{ return text; }

string Submain ()
{
 foreach ( i; taskPool.parallel(Textarr[0 .. $], 1))
   {
        auto Task = task(&fn, i);
        Task.executeInNewThread();
        auto TaskData = Task.workForce;
        Data ~= TaskData;
  }
  return Data;
}

void main ()
{
 Submain;
 writeln(Data[0 .. $]);
}

From,
Vino.B

Hi All,

  Was able to find a solution, but the output writes additional 
empty lines., request your help on how to print without the empty 
lines.

Program:
import std.stdio;
import std.parallelism;
import std.algorithm;
import std.string;
string Data;
auto Textarr = [ "Welcome", "Home" ];
string endresult;
string fn (string text)
{ return text; }

void main ()
{
 string text;
 auto endresult = taskPool.workerLocalStorage(text);
 foreach ( i; parallel(Textarr[0 .. $], 1))
   {
        auto Task = task(&fn, i);
        Task.executeInNewThread();
        auto TaskData = Task.workForce;
        endresult.get ~= TaskData;
  }
  foreach (i; sums.toRange)
   { writeln(i); }
}

Output:
C:\Users\admin\Desktop\Script>rdmd test.d
Welcome
Home







C:\Users\admin\Desktop\Script>