Если я правильно понял вопрос, вам нужно запустить экземпляр элемента управления WebBrowser
на время жизни вашей библиотеки и сохранить его живым и независимым от выделенного потока STA с собственным циклом сообщений WinForms.
В приведенном ниже коде показано, как это можно сделать, используя вспомогательный класс с именем MessageLoopApartment
. Обратите внимание, как WebBrowser
создается и обрабатывается в отдельном потоке.
Параллельная библиотека задач очень удобна для выполнения задачи синхронизации. Задачи, запланированные в потоке STA с помощью MessageLoopApartment.Run
, могут ожидаться синхронно с task.Wait()
или асинхронно с await task
, результаты и исключения распространяются из потока STA через Task.Result
/Task.Execption
, исключения повторно выбрасываются в кадр стека вызывающей стороны.
Реализация MessageLoopApartment
совместима с NET 4.0 и не использует никаких функций .NET 4.5. Клиентский код (тест навигации WebBrowser
) необязательно использует async/await
, для чего может потребоваться Microsoft.Bcl.Async
для .NET 4.0. TPL и async/await
значительно упрощают управление объектами, созданными внутри потока MessageLoopApartment
, например _webBrowser
.
Навигационный тест выполняется внутри MainForm_Load
, но время жизни _webBrowser
и _apartment
не ограничивается границами этого единственного вызова. Оба уничтожаются внутри MainForm_FormClosed
. Тестовое приложение — это приложение WinForms, но оно также может быть консольным приложением или чем-то еще.
using System;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;
namespace WinForms_21772632
{
// https://stackoverflow.com/q/21772632/1768303
public partial class MainForm : Form
{
MessageLoopApartment _apartment;
// _webBrowser is created on a separate thread,
// with MessageLoopApartment.Run
WebBrowser _webBrowser;
// MainForm
public MainForm()
{
InitializeComponent();
// create an independent STA thread
_apartment = new MessageLoopApartment();
// create a WebBrowser on that STA thread
_webBrowser = _apartment.Run(
() => new WebBrowser(),
CancellationToken.None).Result;
this.Load += MainForm_Load;
this.FormClosed += MainForm_FormClosed;
}
// navigation test
async void MainForm_Load(object senderLoad, EventArgs eLoad)
{
// navigate
var cts = new CancellationTokenSource(10000); // cancel in 10s
var url = "http://example.com";
var html = await _apartment.Run(async () =>
{
WebBrowserDocumentCompletedEventHandler handler = null;
var navigateTcs = new TaskCompletionSource<bool>();
handler = (s, e) =>
navigateTcs.TrySetResult(true);
_webBrowser.DocumentCompleted += handler;
try
{
using (cts.Token.Register(() => navigateTcs.TrySetCanceled()))
{
_webBrowser.Navigate(url);
await navigateTcs.Task;
return _webBrowser.Document.Body.OuterHtml;
}
}
finally
{
_webBrowser.DocumentCompleted -= handler;
}
},
cts.Token);
// show the HTML of the downloaded page
MessageBox.Show(html);
}
void MainForm_FormClosed(object sender, FormClosedEventArgs e)
{
// destroy the WebBrowser
_apartment.Run(
() => _webBrowser.Dispose(),
CancellationToken.None).Wait();
// shut down the appartment
_apartment.Dispose();
}
}
/// <summary>MessageLoopApartment</summary>
public class MessageLoopApartment : IDisposable
{
Thread _thread; // the STA thread
TaskScheduler _taskScheduler; // the STA thread's task scheduler
public TaskScheduler TaskScheduler { get { return _taskScheduler; } }
/// <summary>MessageLoopApartment constructor</summary>
public MessageLoopApartment()
{
var tcs = new TaskCompletionSource<TaskScheduler>();
// start an STA thread and gets a task scheduler
_thread = new Thread(startArg =>
{
EventHandler idleHandler = null;
idleHandler = (s, e) =>
{
// handle Application.Idle just once
Application.Idle -= idleHandler;
// return the task scheduler
tcs.SetResult(TaskScheduler.FromCurrentSynchronizationContext());
};
// handle Application.Idle just once
// to make sure we're inside the message loop
// and SynchronizationContext has been correctly installed
Application.Idle += idleHandler;
Application.Run();
});
_thread.SetApartmentState(ApartmentState.STA);
_thread.IsBackground = true;
_thread.Start();
_taskScheduler = tcs.Task.Result;
}
/// <summary>shutdown the STA thread</summary>
public void Dispose()
{
if (_taskScheduler != null)
{
var taskScheduler = _taskScheduler;
_taskScheduler = null;
// execute Application.ExitThread() on the STA thread
Task.Factory.StartNew(
() => Application.ExitThread(),
CancellationToken.None,
TaskCreationOptions.None,
taskScheduler).Wait();
_thread.Join();
_thread = null;
}
}
/// <summary>A wrapper around Task.Factory.StartNew</summary>
public Task Run(Action action, CancellationToken token)
{
return Task.Factory.StartNew(action, token, TaskCreationOptions.None, _taskScheduler);
}
/// <summary>A wrapper around Task.Factory.StartNew to run lambdas with a result</summary>
public Task<TResult> Run<TResult>(Func<TResult> action, CancellationToken token)
{
return Task.Factory.StartNew(action, token, TaskCreationOptions.None, _taskScheduler);
}
/// <summary>A wrapper around Task.Factory.StartNew to run async lambdas</summary>
public Task Run(Func<Task> action, CancellationToken token)
{
return Task.Factory.StartNew(action, token, TaskCreationOptions.None, _taskScheduler).Unwrap();
}
/// <summary>A wrapper around Task.Factory.StartNew to run async lambdas with a result</summary>
public Task<TResult> Run<TResult>(Func<Task<TResult>> action, CancellationToken token)
{
return Task.Factory.StartNew(action, token, TaskCreationOptions.None, _taskScheduler).Unwrap();
}
}
}
person
noseratio
schedule
14.02.2014
async
. Спасибо Ганс. - person dotNET   schedule 14.02.2014