c# - 我可以使用响应式扩展来排队调用 Windows 服务吗？

Question

我有一个窗口服务正在调用一个非线程安全的 api (ghostscript) 将 pdf 转换为图像，所以我需要确保一次调用一个方法调用，但将所有可能来自各种调用的调用排队应用实例。

应用程序 -> Windows 服务 -> ghostscript

Answer 1

给你:

var eventLoop = new EventLoopScheduler();

IObservable<Unit> QueueAnItem(string input) 
{
    return Observable.Start(() => CallGhostScriptAndWaitForItToFinish(input), eventLoop);
}

QueueAnItem("Foo").Subscribe(
    x => Console.WriteLine("It Finished!"), 
    ex => Console.WriteLine("Something Bad Happened: {0}", ex.ToString());