I am trying to play with PLINQ, and I was wondering, if I have an enumerable that, say, reads lines from a file, or stock prices off Yahoo Finance, would AsParallel() call it from one thread or from multiple threads concurrently. Experiment shows that it’s the latter:<\/p>\n
class Program\n{\n [ThreadStatic]\n static int Index = 0;\n\n static IEnumerable GetStrings()\n {\n while (true)\n {\n yield return String.Format(\"Thread {0} String {1}\", Thread.CurrentThread.ManagedThreadId, ++Index);\n }\n }\n\n static void Main(string[] args)\n {\n using (var writer = new ParallelTextWriter(\"out{0}.txt\"))\n {\n GetStrings().AsParallel().Take(1000).ForAll(s => { writer.WriteLine(s); });\n }\n }\n}<\/code><\/pre>\nThe output is<\/p>\n
Thread 1 String 1
\nThread 1 String 2
\n...
\nThread 1 String 800
\nThread 3 String 1
\nThread 3 String 2
\n...
\nThread 3 String 200<\/code><\/p>\nObviously, the ratio of strings between threads (800\/200 or 500\/500) could be different each time.
\n