好的，下面的链接有一个警告，说明讨论使用了不受支持和未记录的 api。好吧，我正在尝试以任何方式使用代码示例。它主要工作。关于以下与例外有关的具体问题的任何想法？
http://msdn.microsoft.com/en-us/magazine/cc164086.aspx
仅供参考，我对原始样本进行了改进。它正在维护一个指向“previousfiber”的指针。相反，下面的更新示例使用了一个“mainfiber”指针，该指针被传递给每个光纤类。这样，它们总是屈服于主纤维。这允许主纤程处理所有其他纤程的调度。其他纤维总是“屈服”回主要纤维。
发布此问题的原因与在光纤中抛出异常有关。根据文章，通过使用带有 CreateLogicalThreadState()、SwitchOutLogicalThreadState() 等的 CorBindToRunTime API，框架将为每个纤程创建一个托管线程并正确处理异常。
但是，在包含的代码示例中，它有一个 UUnit 测试，该测试尝试在 Fiber 中抛出托管异常并在同一 Fiber 中捕获它。那种柔软的作品。但是在通过记录消息处理它之后，堆栈似乎处于错误状态，因为如果纤程调用任何其他方法甚至是空方法，整个应用程序都会崩溃。
这对我来说意味着 SwitchOutLogicalThreadState() 和 SwitchInLogicalThreadState() 可能没有被正确使用，或者他们可能没有做他们的工作。
注意：问题的一个线索是托管代码注销了 Thread.CurrentThread.ManagedThreadId 并且每个光纤都相同。这表明 CreateLogicalThreadState() 方法并没有像宣传的那样真正创建新的托管线程。
为了更好地分析这一点，我制作了一个伪代码列表，列出了调用来处理纤程的低级 API 的顺序。请记住，纤程都在同一个线程上运行，因此不会同时发生任何事情，这是一个线性逻辑。必要的技巧当然是保存和恢复堆栈。这就是它似乎遇到麻烦的地方。
它开始只是一个线程，然后它转换为纤维：
- ConvertThreadToFiber(objptr);
- CreateFiber() // 创建几个 win32 光纤。
现在第一次调用一个纤程，它的启动方法是这样的：
- corhost->SwitchOutLogicalThreadState(&cookie); 主 cookie 保存在堆栈中。
- SwitchToFiber(); // 第一次调用光纤启动方法
- corhost->CreateLogicalThreadState();
- 运行主要的纤维抽象方法。
最终，纤维需要屈服于主纤维：
- corhost->SwitchOutLogicalThreadState(&cookie);
- SwitchToFiber(光纤);
- corhost->SwitchInLogicalThreadState(&cookie); // 主要的纤维饼干，对吧？
主纤维也将恢复先前存在的纤维：
- corhost->SwitchOutLogicalThreadState(&cookie);
- SwitchToFiber(光纤);
- corhost->SwitchInLogicalThreadState(&cookie); // 主要的纤维饼干，对吧？
以下是为托管代码包装了 fiber api 的 fiber.cpp。
#define _WIN32_WINNT 0x400
#using <mscorlib.dll>
#include <windows.h>
#include <mscoree.h>
#include <iostream>
using namespace std;
#if defined(Yield)
#undef Yield
#endif
#define CORHOST
namespace Fibers {
typedef System::Runtime::InteropServices::GCHandle GCHandle;
VOID CALLBACK unmanaged_fiberproc(PVOID pvoid);
__gc private struct StopFiber {};
enum FiberStateEnum {
FiberCreated, FiberRunning, FiberStopPending, FiberStopped
};
#pragma unmanaged
#if defined(CORHOST)
ICorRuntimeHost *corhost;
void initialize_corhost() {
CorBindToCurrentRuntime(0, CLSID_CorRuntimeHost,
IID_ICorRuntimeHost, (void**) &corhost);
}
#endif
void CorSwitchToFiber(void *fiber) {
#if defined(CORHOST)
DWORD *cookie;
corhost->SwitchOutLogicalThreadState(&cookie);
#endif
SwitchToFiber(fiber);
#if defined(CORHOST)
corhost->SwitchInLogicalThreadState(cookie);
#endif
}
#pragma managed
__gc __abstract public class Fiber : public System::IDisposable {
public:
#if defined(CORHOST)
static Fiber() { initialize_corhost(); }
#endif
Fiber() : state(FiberCreated) {
void *objptr = (void*) GCHandle::op_Explicit(GCHandle::Alloc(this));
fiber = ConvertThreadToFiber(objptr);
mainfiber = fiber;
//System::Console::WriteLine( S"Created main fiber.");
}
Fiber(Fiber *_mainfiber) : state(FiberCreated) {
void *objptr = (void*) GCHandle::op_Explicit(GCHandle::Alloc(this));
fiber = CreateFiber(0, unmanaged_fiberproc, objptr);
mainfiber = _mainfiber->fiber;
//System::Console::WriteLine(S"Created worker fiber");
}
__property bool get_IsRunning() {
return state != FiberStopped;
}
int GetHashCode() {
return (int) fiber;
}
bool Resume() {
if(!fiber || state == FiberStopped) {
return false;
}
if( state == FiberStopPending) {
Dispose();
return false;
}
void *current = GetCurrentFiber();
if(fiber == current) {
return false;
}
CorSwitchToFiber(fiber);
return true;
}
void Dispose() {
if(fiber) {
void *current = GetCurrentFiber();
if(fiber == current) {
state = FiberStopPending;
CorSwitchToFiber(mainfiber);
}
state = FiberStopped;
System::Console::WriteLine( S"\nDeleting Fiber.");
DeleteFiber(fiber);
fiber = 0;
}
}
protected:
virtual void Run() = 0;
void Yield() {
CorSwitchToFiber(mainfiber);
if(state == FiberStopPending)
throw new StopFiber;
}
private:
void *fiber, *mainfiber;
FiberStateEnum state;
private public:
void main() {
state = FiberRunning;
try {
Run();
} catch(System::Object *x) {
System::Console::Error->WriteLine(
S"\nFIBERS.DLL: main Caught {0}", x);
}
Dispose();
}
};
void fibermain(void* objptr) {
//System::Console::WriteLine( S"\nfibermain()");
System::IntPtr ptr = (System::IntPtr) objptr;
GCHandle g = GCHandle::op_Explicit(ptr);
Fiber *fiber = static_cast<Fiber*>(g.Target);
g.Free();
fiber->main();
System::Console::WriteLine( S"\nfibermain returning");
}
#pragma unmanaged
VOID CALLBACK unmanaged_fiberproc(PVOID objptr) {
#if defined(CORHOST)
corhost->CreateLogicalThreadState();
#endif
fibermain(objptr);
#if defined(CORHOST)
corhost->DeleteLogicalThreadState();
#endif
}
}
上面的fibers.cpp类文件是Visaul c++项目中唯一的类。它使用 /CLR:oldstyle 开关构建为具有 CLR 支持的 DLL。
using System;
using System.Threading;
using Fibers;
using NUnit.Framework;
namespace TickZoom.Utilities
{
public class FiberTask : Fiber
{
public FiberTask()
{
}
public FiberTask(FiberTask mainTask)
: base(mainTask)
{
}
protected override void Run()
{
while (true)
{
Console.WriteLine("Top of worker loop.");
try
{
Work();
}
catch (Exception ex)
{
Console.WriteLine("Exception: " + ex.Message);
}
Console.WriteLine("After the exception.");
Work();
}
}
private void Work()
{
Console.WriteLine("Doing work on fiber: " + GetHashCode() + ", thread id: " + Thread.CurrentThread.ManagedThreadId);
++counter;
Console.WriteLine("Incremented counter " + counter);
if (counter == 2)
{
Console.WriteLine("Throwing an exception.");
throw new InvalidCastException("Just a test exception.");
}
Yield();
}
public static int counter;
}
[TestFixture]
public class TestingFibers
{
[Test]
public void TestIdeas()
{
var fiberTasks = new System.Collections.Generic.List<FiberTask>();
var mainFiber = new FiberTask();
for( var i=0; i< 5; i++)
{
fiberTasks.Add(new FiberTask(mainFiber));
}
for (var i = 0; i < fiberTasks.Count; i++)
{
Console.WriteLine("Resuming " + i);
var fiberTask = fiberTasks[i];
if( !fiberTask.Resume())
{
Console.WriteLine("Fiber " + i + " was disposed.");
fiberTasks.RemoveAt(i);
i--;
}
}
for (var i = 0; i < fiberTasks.Count; i++)
{
Console.WriteLine("Disposing " + i);
fiberTasks[i].Dispose();
}
}
}
}
上面的单元测试给出以下输出，然后严重崩溃：
Resuming 0
Top of worker loop.
Doing work on fiber: 476184704, thread id: 7
Incremented counter 1
Resuming 1
Top of worker loop.
Doing work on fiber: 453842656, thread id: 7
Incremented counter 2
Throwing an exception.
Exception: Just a test exception.
After the exception.