一个有趣的库编写者的困境。在我的库(在这种情况下是EasyNetQ)中,我正在分配线程本地资源。因此,当客户端创建一个新线程并调用我的库的某些方法时,会创建新资源。在EasyNetQ的情况下,当客户端在新线程上调用“Publish”时,将创建到RabbitMQ服务器的新通道。我想能够检测到客户端线程退出,以便我可以清理资源(通道)。
我能想到的唯一方法是创建一个新的“watcher”线程,它只是在客户端线程上阻塞Join调用。下面是一个简单的演示:
首先是我的“库”。它获取客户端线程,然后创建一个新线程,在该线程上阻塞“Join”:
public class Library
{
public void StartSomething()
{
Console.WriteLine("Library says: StartSomething called");
var clientThread = Thread.CurrentThread;
var exitMonitorThread = new Thread(() =>
{
clientThread.Join();
Console.WriteLine("Libaray says: Client thread existed");
});
exitMonitorThread.Start();
}
}
这是一个使用我的库的客户端。它创建了一个新线程,然后调用了我的库的StartSomething方法:
public class Client
{
private readonly Library library;
public Client(Library library)
{
this.library = library;
}
public void DoWorkInAThread()
{
var thread = new Thread(() =>
{
library.StartSomething();
Thread.Sleep(10);
Console.WriteLine("Client thread says: I'm done");
});
thread.Start();
}
}
当我以这种方式运行客户端时:
var client = new Client(new Library());
client.DoWorkInAThread();
// give the client thread time to complete
Thread.Sleep(100);
我得到了这个输出:
Library says: StartSomething called
Client thread says: I'm done
Libaray says: Client thread existed
它能够工作,但是很丑陋。我真的不喜欢所有这些被阻止的监视线程挂起来的想法。有没有更好的方法?
第一种替代方案。
提供一个返回实现IDisposable接口的worker方法,并在文档中明确指出不应在线程之间共享workers。以下是修改后的库:
public class Library
{
public LibraryWorker GetLibraryWorker()
{
return new LibraryWorker();
}
}
public class LibraryWorker : IDisposable
{
public void StartSomething()
{
Console.WriteLine("Library says: StartSomething called");
}
public void Dispose()
{
Console.WriteLine("Library says: I can clean up");
}
}
现在客户端变得更加复杂了:
public class Client
{
private readonly Library library;
public Client(Library library)
{
this.library = library;
}
public void DoWorkInAThread()
{
var thread = new Thread(() =>
{
using(var worker = library.GetLibraryWorker())
{
worker.StartSomething();
Console.WriteLine("Client thread says: I'm done");
}
});
thread.Start();
}
}
这个变化的主要问题在于它会破坏API,现有的客户端将不得不重新编写。但这并不是什么坏事,这意味着需要重新检查它们并确保清理工作正确完成。非破坏性的第二种替代方案是,API提供了一种让客户端声明“工作范围”的方式。一旦范围完成,库就可以进行清理。该库提供了一个实现IDisposable接口的WorkScope,但与上述第一种替代方案不同,StartSomething方法保留在Library类中。
public class Library
{
public WorkScope GetWorkScope()
{
return new WorkScope();
}
public void StartSomething()
{
Console.WriteLine("Library says: StartSomething called");
}
}
public class WorkScope : IDisposable
{
public void Dispose()
{
Console.WriteLine("Library says: I can clean up");
}
}
客户端只需在 WorkScope 中添加 StartSomething 调用...
public class Client
{
private readonly Library library;
public Client(Library library)
{
this.library = library;
}
public void DoWorkInAThread()
{
var thread = new Thread(() =>
{
using(library.GetWorkScope())
{
library.StartSomething();
Console.WriteLine("Client thread says: I'm done");
}
});
thread.Start();
}
}
我喜欢这个方案比第一个更少,因为它不强制要求库用户考虑作用域。