Вернуть управление вызывающему потоку

[yudjin]

Распараллелил функцию в главном потоке (средствами Rx Framework, но это значения не имеет, пробовал и через BeginInvoke()):

public void Start()
        {
            //...
            var startSession = Observable.ToAsync<string, string>(this.StartSession);
            startSession(credentionals.Login, credentionals.Password);
            //...
        }

Она вызывает асинхронно долгоиграющий метод, который в конце должен кинуть эвент всем, кто его слушает:

private void StartSession(string login, string password)
        {
            //...
            this.OnStarted(EventArgs.Empty);
        }

Встал вопрос - как сделать так, чтоб метод this.OnStarted() вызывался в главном потоке? Не могу понять, возможно ли это вообще.
Знаю, что обратная сторона Fork'а - Join, но при его помощи не выходит "слить" потоки обратно.

Из многопоточности пока только освоил разделение, lock'и и ManualResetEvent's  

PS: дело в том, что подписчики на событие Started - в основном GUI-компоненты, и они вредничают, если менять их не из главного потока. Переделывать UI на безопасные BeginInvoke() - много мороки, много кода уже написано.
Еще раз пересмотрел все темы про потоки - ничего подобного там нет... Я так понял, это связано больше с параллелизмом, но ведь даже за всеми фреймворками по паралеллизму стоят рядовые инструменты, значит это можно сделать стандартными средствами.

[Dimka]

yudjin, вызвать метод в "другом" уже работающем потоке не так-то просто. Но принцип сводится к тому, что тот поток должен либо ждать события, либо периодически проверять наступление события и при наличии события вызывать метод OnStarted. По-другому - никак.

Если "другой" поток - это GUI, то разумно рассмотреть возможность посылки сообщения с помощью WinAPI в очередь приложения и обработки обычным образом.

[yudjin]

Просто для завершения картины выложу выбранное решение.

Отсоединяем поток:

Код:

public void Start()
        {

            //...
            this.synchronizationContext = SynchronizationContext.Current ?? new SynchronizationContext();
            var startSession = Observable.ToAsync<string, string>(this.StartSession);
            startSession(credentionals.Login, credentionals.Password);                                
            //...
        }

Посылаем сообщение вызывающему потоку и оттуда уже дергаем нужный метод

Код:

 private void StartSession(string login, string password)
        {
            //...
            this.synchronizationContext.Post(state => this.OnStarted(EventArgs.Empty), null);   
        }