C# yield return 枚举器,从部分继续
C# yield return enumerator, continue from part the way through
我正在使用 yield return 处理一些数据,其中包含一组不确定的迭代。我想开始处理,但是一旦满足条件(例如字节大小)就中断循环,将枚举器传递给将继续处理的新线程,然后 return 到目前为止处理的结果。
实际上我有一个 foreach 循环,我很可能会在结束前跳出。如何将 IEnumerable 传递给新线程并从我离开的地方而不是开始的地方 'continue' 传递?
public static IEnumerable<String> Process()
{
// static values added for simplicity, but will be a variable number of returns
yield return "1";
yield return "2";
yield return "3";
yield return "4";
yield return "5";
yield return "6";
}
List<String> main()
{
List<String> retVal = new List<String>();
IEnumerable<String> strList = Process();
foreach(String strItem in strList)
{
retVal.Add(strItem);
Console.WriteLine(strItem);
// Time to send something back and continue in a new thread
if (strItem.Equals("3"))
{
break;
}
}
new Thread(() => ThreadFunc(strList)).Start();
return retVal;
}
public static void ThreadFunc(IEnumerable<String> strList)
{
List<String> retVal = new List<String>();
foreach(String strItem in strList)
{
retVal.Add(strItem);
Console.WriteLine(strItem);
}
// Send the rest of the data
}
期望输出:1 2 3 4 5 6
实际输出:1 2 3 1 2 3 4 5 6
谢谢。
看看 IEnumerable<T>
接口实际做了什么。
IEnumerable<T>
完全无状态;它只是公开了一个 GetEnumerator()
方法,该方法返回有状态的枚举器来跟踪它们的位置。
您需要在两个循环之间传递相同的 enumerator 实例。 foreach
只能在 IEnumerable<T>
(或类似的)上运行,因此您需要将它们替换为直接使用 IEnumerator<T>
的 while
循环。
确保在所有代码路径中放置 IEnumerator
(否则,finally
或 using
块不会 运行)。
我正在使用 yield return 处理一些数据,其中包含一组不确定的迭代。我想开始处理,但是一旦满足条件(例如字节大小)就中断循环,将枚举器传递给将继续处理的新线程,然后 return 到目前为止处理的结果。
实际上我有一个 foreach 循环,我很可能会在结束前跳出。如何将 IEnumerable 传递给新线程并从我离开的地方而不是开始的地方 'continue' 传递?
public static IEnumerable<String> Process()
{
// static values added for simplicity, but will be a variable number of returns
yield return "1";
yield return "2";
yield return "3";
yield return "4";
yield return "5";
yield return "6";
}
List<String> main()
{
List<String> retVal = new List<String>();
IEnumerable<String> strList = Process();
foreach(String strItem in strList)
{
retVal.Add(strItem);
Console.WriteLine(strItem);
// Time to send something back and continue in a new thread
if (strItem.Equals("3"))
{
break;
}
}
new Thread(() => ThreadFunc(strList)).Start();
return retVal;
}
public static void ThreadFunc(IEnumerable<String> strList)
{
List<String> retVal = new List<String>();
foreach(String strItem in strList)
{
retVal.Add(strItem);
Console.WriteLine(strItem);
}
// Send the rest of the data
}
期望输出:1 2 3 4 5 6
实际输出:1 2 3 1 2 3 4 5 6
谢谢。
看看 IEnumerable<T>
接口实际做了什么。
IEnumerable<T>
完全无状态;它只是公开了一个 GetEnumerator()
方法,该方法返回有状态的枚举器来跟踪它们的位置。
您需要在两个循环之间传递相同的 enumerator 实例。 foreach
只能在 IEnumerable<T>
(或类似的)上运行,因此您需要将它们替换为直接使用 IEnumerator<T>
的 while
循环。
确保在所有代码路径中放置 IEnumerator
(否则,finally
或 using
块不会 运行)。