ReSQL.ru
     
powered by simpleCommunicator - 2.0.51     © 2025 Programmizd 02
Мобильная версия    Контакт    Правила    FAQ    Помощь
Доб. в избранное | Игнор. тему | Прикреп. тему | Пометить прочит. / непрочит. | Фильтр
Форумы / WPF, Silverlight [игнор отключен] [закрыт для гостей] / [SL] Одна переменная для нескольких обработчиков
15 сообщений из 40, страница 2 из 2
  2  все
[SL] Одна переменная для нескольких обработчиков
    #37840809
ViPRos
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
ViPRos
Участник
SeVa,

rx развивается?
...
Рейтинг: 0 / 0
16.06.2012, 12:49
| Ответить | Цитировать | Написать  
[SL] Одна переменная для нескольких обработчиков
    #37840821
Фотография Алексей К
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Алексей К
Участник
SeVaЭлементарно
Код: c#
1.
2.
3.
4.
5.
var res = from t1 in Observable.Return(Task1())
              from t2 in Observable.Return(Task2())
              select t1+t2;
or
    Observable.Return(Task1()).And(Observable.Return(Task2()).Then((t1,t2) = > t1+t2)

Неправильно. Метод Task2() должен принимать результат выполнения метода Task1(). Для чистоты эксперивента возьми за основу методы F1, F2 и F3 из моего примера. Преобразуй возвращаемые ими Task в IObservable (вроде это несложно) и покажи как будет выглядеть цепочка вызовов на Rx. Мне правда интересно. :-)

SeVaПример и вопрос примитивный, тк task'и только под это заточены, а у rx возможностей большеБольшего не требуется. Мне надо чтобы именно это описывалось максимально удобным кодом.
...
Рейтинг: 0 / 0
16.06.2012, 13:00
| Ответить | Цитировать | Написать  
[SL] Одна переменная для нескольких обработчиков
    #37840846
SeVa
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
SeVa
Участник
Алексей КSeVaЭлементарно
Код: c#
1.
2.
3.
4.
5.
var res = from t1 in Observable.Return(Task1())
              from t2 in Observable.Return(Task2())
              select t1+t2;
or
    Observable.Return(Task1()).And(Observable.Return(Task2()).Then((t1,t2) = > t1+t2)

Неправильно. Метод Task2() должен принимать результат выполнения метода Task1(). Для чистоты эксперивента возьми за основу методы F1, F2 и F3 из моего примера. Преобразуй возвращаемые ими Task в IObservable (вроде это несложно) и покажи как будет выглядеть цепочка вызовов на Rx. Мне правда интересно. :-)

SeVaПример и вопрос примитивный, тк task'и только под это заточены, а у rx возможностей большеБольшего не требуется. Мне надо чтобы именно это описывалось максимально удобным кодом.

Код: sql
1.
2.
3.
4.
5.
var res = from t1 in Observable.Return(Task1())
              from t2 in Observable.Return(Task2(t1))
              from t3 in Observable.Return(Task2(t2))
              etc
              select t48;


Частная задача, а требуется значительно больше. Таски Без поддержки всех операторов linq
- жалкая полова.
Чуть усложним. Покажи код, когда Task1&Task2 выполняются последовательно,Task3 параллено им, все они возвращают коллекции и нужно определить минимальное и максимальное значение в объединенном наборе.Плюс должна быть обработка ошибок.
...
Рейтинг: 0 / 0
16.06.2012, 13:37
| Ответить | Цитировать | Написать  
[SL] Одна переменная для нескольких обработчиков
    #37840856
Фотография Алексей К
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Алексей К
Участник
SeVa
Код: sql
1.
2.
3.
4.
5.
var res = from t1 in Observable.Return(Task1())
              from t2 in Observable.Return(Task2(t1))
              from t3 in Observable.Return(Task2(t2))
              etc
              select t48;

Ок, пасиб.
SeVaТаски Без поддержки всех операторов linq
- жалкая полова.Да ну. Это уже бантики.
SeVaЧуть усложним. Покажи код, когда Task1&Task2 выполняются последовательно,Task3 параллено им, все они возвращают коллекции и нужно определить минимальное и максимальное значение в объединенном наборе.Плюс должна быть обработка ошибок.
Код: c#
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
var t1 = Task1()
    .ContinueWith(t => Task2(t.Result))
    .Unwrap();

var t2 = Task3();

Task.Factory
    .ContunueWhenAll(
        new[] {t1, t2},
        tt =>
        {
              var items = t1.Result.Concat(t2.Result);
              Console.WriteLine(items.Min());
              Console.WriteLine(items.Max());
        }
    )
    .LogExceptions();

////////////////////

public static class TaskHelper
{
    public static void LogExceptions(this Task task)
    {
        if (task.Exception != null)
            Log.AddException(task.Exception);
    }
}
...
Рейтинг: 0 / 0
16.06.2012, 13:51
| Ответить | Цитировать | Написать  
[SL] Одна переменная для нескольких обработчиков
    #37841017
SeVa
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
SeVa
Участник
ViPRosSeVa,

rx развивается?

Да, есть уже бета 2.0 и будет native rx для winrt
...
Рейтинг: 0 / 0
16.06.2012, 17:20
| Ответить | Цитировать | Написать  
[SL] Одна переменная для нескольких обработчиков
    #37841036
SeVa
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
SeVa
Участник
Алексей КSeVa
Код: sql
1.
2.
3.
4.
5.
var res = from t1 in Observable.Return(Task1())
              from t2 in Observable.Return(Task2(t1))
              from t3 in Observable.Return(Task2(t2))
              etc
              select t48;

Ок, пасиб.
SeVaТаски Без поддержки всех операторов linq
- жалкая полова.Да ну. Это уже бантики.
SeVaЧуть усложним. Покажи код, когда Task1&Task2 выполняются последовательно,Task3 параллено им, все они возвращают коллекции и нужно определить минимальное и максимальное значение в объединенном наборе.Плюс должна быть обработка ошибок.
Код: c#
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
var t1 = Task1()
    .ContinueWith(t => Task2(t.Result))
    .Unwrap();

var t2 = Task3();

Task.Factory
    .ContunueWhenAll(
        new[] {t1, t2},
        tt =>
        {
              var items = t1.Result.Concat(t2.Result);
              Console.WriteLine(items.Min());
              Console.WriteLine(items.Max());
        }
    )
    .LogExceptions();

////////////////////

public static class TaskHelper
{
    public static void LogExceptions(this Task task)
    {
        if (task.Exception != null)
            Log.AddException(task.Exception);
    }
}


Весьма замысловато и неудобно, тк с полученными результатами можно работать только через одно место. C rx это делается в одну строчку
...
Рейтинг: 0 / 0
16.06.2012, 17:45
| Ответить | Цитировать | Написать  
[SL] Одна переменная для нескольких обработчиков
    #37842090
Фотография Алексей К
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Алексей К
Участник
SeVaВесьма замысловато и неудобно, тк с полученными результатами можно работать только через одно место.Дискомфорта не испытываю. Если захочется LINQ - таски всегда можно преобразовать в IObservable.
...
Рейтинг: 0 / 0
18.06.2012, 05:42
| Ответить | Цитировать | Написать  
[SL] Одна переменная для нескольких обработчиков
    #37843401
SeVa
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
SeVa
Участник
Алексей КSeVaВесьма замысловато и неудобно, тк с полученными результатами можно работать только через одно место.Дискомфорта не испытываю. Если захочется LINQ - таски всегда можно преобразовать в IObservable.

Таски - процедурный стиль, rx - фукциональный. DbReader vs linq
...
Рейтинг: 0 / 0
18.06.2012, 23:18
| Ответить | Цитировать | Написать  
[SL] Одна переменная для нескольких обработчиков
    #37875792
enigmatic
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
enigmatic
Участник
Алексей КenigmaticНо ведь консольное приложение отрабатывает нормально. Уверен, проблемы из-за отличия CLR SL от CLR обычного дотнета.Нет. Отличие в том, что приложение консольное. А в силверлайтном приложении возникает мёртвая блокировка. Ожидание завершения при обращении к свойству task.Result в конструкторе в гуйном потоке + событие завершения идёт в гуйном потоке == мёртвая блокировка.Хотелось бы поблагодарить автора за этот ответ, т.к. этот ответ я пропустил.
Вот здесь дали почти такой же, потом я собрался перепостить его сюда, а оказалось, что он здесь уже есть =)

Алексей К , мне бы ваш опыт в понимании именно возникающего дедлока =)
SeVaМогут и будут. Асинхронные вызовы могут выполняться в разной последовательности, вызовы нужно делать с дополнительным параметром state, который нужно анализировать в обработчике. Помимо этого есть утечки памяти. При множественных вызовах webrequest - более предпочтительных вариант, тк нет лишней диспетчеризации в ui поток.>Асинхронные вызовы могут выполняться в разной последовательности
>вызовы нужно делать с дополнительным параметром state
Чтобы иметь возможность их различать. При описанном в первом посте подходе этого не требуется.
>Помимо этого есть утечки памяти
Я бы попросил поподробнее, пожалуйста.
>При множественных вызовах webrequest - более предпочтительных вариант, тк нет лишней диспетчеризации в ui поток.
Согласен.
...
Рейтинг: 0 / 0
12.07.2012, 07:20
| Ответить | Цитировать | Написать  
[SL] Одна переменная для нескольких обработчиков
    #37875806
Фотография Алексей К
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Алексей К
Участник
enigmatic>Асинхронные вызовы могут выполняться в разной последовательности
>вызовы нужно делать с дополнительным параметром state
Чтобы иметь возможность их различать. При описанном в первом посте подходе этого не требуется.
Асинхронные операции могут завершится не в том порядке, в котором их запускали. Часто в GUI-приложении нужен результат только последнего запущенного таска, если произошло несколько запусков одновременно. Одним из решений является передача state object с идентификатором, который проверяется при завершении операции. Мне же больше нравится такое решение:
 
Идеальный код :-)
Код: c#
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
40.
41.
42.
43.
44.
45.
class MyClass
{
    Task<int> GetDataLastTask;

    void Execute() // как правило это вызывается в гуйном потоке
    {
        GetDataLastTask = GetData();
        GetDataLastTask
            .ContinueWith(t => // как правило это синхронизировано с гуйным потоком
            {
                if (t != GetDataLastTask)
                {
                    t.ThrowIfException();
                    return;
                }
                 
                // тут работаем с t.Result

            })
            .LogExceptions();
    }

    Task<int> GetData()
    {
        return Task.Factory....
    }
}

public static class TaskHelper
{
    public static void LogExceptions(this Task task)
    {
        task.ContinueWith(t =>
        {
            if (t.Exception != null)
                Log.AddException(t.Exception);
        });
    }

    public static void ThrowIfException(this Task task)
    {
        if (task.Exception != null)
            throw new AggregateException(task.Exception);
    }
}

Это решение, наверное, не на все случаи жизни, но часто его достаточно. Главное, что оно не зависит от предметной области, в отличие от решения через state object.

автор>Помимо этого есть утечки памяти
Я бы попросил поподробнее, пожалуйста.Я утечек памяти не заметил.
...
Рейтинг: 0 / 0
12.07.2012, 08:06
| Ответить | Цитировать | Написать  
[SL] Одна переменная для нескольких обработчиков
    #37876269
enigmatic
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
enigmatic
Участник
Алексей КАсинхронные операции могут завершится не в том порядке, в котором их запускали. Часто в GUI-приложении нужен результат только последнего запущенного таска, если произошло несколько запусков одновременно. Одним из решений является передача state object с идентификатором, который проверяется при завершении операции.
Да, конечно. Но при описанном подходе ничего проверять не нужно, т.к. колбек таска жестко связан с его вызовом, и если нам нужно сделать обработку только последнего запущенного таска, то мы просто описываем эту обработку в колбеке последнего таска.
Напротив, если использовать события - то обработчики не связаны с запрашивающими методами и нам нужны object state, чтобы понять, какой из обработчиков какому запросу соответствует.

Алексей КМне же больше нравится такое решение:
 
Идеальный код :-)
Код: c#
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
40.
41.
42.
43.
44.
45.
class MyClass
{
    Task<int> GetDataLastTask;

    void Execute() // как правило это вызывается в гуйном потоке
    {
        GetDataLastTask = GetData();
        GetDataLastTask
            .ContinueWith(t => // как правило это синхронизировано с гуйным потоком
            {
                if (t != GetDataLastTask)
                {
                    t.ThrowIfException();
                    return;
                }
                 
                // тут работаем с t.Result

            })
            .LogExceptions();
    }

    Task<int> GetData()
    {
        return Task.Factory....
    }
}

public static class TaskHelper
{
    public static void LogExceptions(this Task task)
    {
        task.ContinueWith(t =>
        {
            if (t.Exception != null)
                Log.AddException(t.Exception);
        });
    }

    public static void ThrowIfException(this Task task)
    {
        if (task.Exception != null)
            throw new AggregateException(task.Exception);
    }
}

Это решение, наверное, не на все случаи жизни, но часто его достаточно. Главное, что оно не зависит от предметной области, в отличие от решения через state object.
Если честно, меня терзают смутные сомнения, что у меня то же самое, но не на тасках =)
Но таски (точнее не самими тасками, а контексте использования потоков), как видите, не пошли сразу и сходу, т.к. нужно понимать особенности диспетчеризации потоков, чем я пока похвастаться не могу :)
Я еще посмотрю ваш идеальный код (когда поумнею :))
...
Рейтинг: 0 / 0
12.07.2012, 12:00
| Ответить | Цитировать | Написать  
[SL] Одна переменная для нескольких обработчиков
    #37876302
enigmatic
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
enigmatic
Участник
enigmatic...
Да, конечно. Но при описанном подходе ничего проверять не нужно, т.к. колбек таска жестко связан с его вызовом, и если нам нужно сделать обработку только последнего запущенного таска, то мы просто описываем эту обработку в колбеке последнего таска.
Напротив, если использовать события - то обработчики не связаны с запрашивающими методами и нам нужны object state, чтобы понять, какой из обработчиков какому запросу соответствует.Что-то я посмотрел первый пост и понял, что описанное неочевидно. Если хотите, я могу сделать выполнение обработки последнего запущенного таска и/или последнего принятого ответа. Будет показательный пример.
...
Рейтинг: 0 / 0
12.07.2012, 12:11
| Ответить | Цитировать | Написать  
[SL] Одна переменная для нескольких обработчиков
    #37876398
Фотография Алексей К
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Алексей К
Участник
enigmaticДа, конечно. Но при описанном подходе ничего проверять не нужно, т.к. колбек таска жестко связан с его вызовом, и если нам нужно сделать обработку только последнего запущенного таска, то мы просто описываем эту обработку в колбеке последнего таска.На каждый асинхронный вызов создаётся новый объект таска. Мы подписываемся на результат выполнения всех запущенных тасков, например, через ContinueWith. Может оказаться, что последний запущенный таск не будет последним выполненным. Типичная ситуация, master-detail. Может оказаться, что текущей записи в списке master будет показан detail "предыдущей текущей" записи в master.
enigmaticНапротив, если использовать события - то обработчики не связаны с запрашивающими методами и нам нужны object state, чтобы понять, какой из обработчиков какому запросу соответствует.Тут ситуация аналогична, просто единственным способом будет передача state object.
enigmaticЕсли хотите, я могу сделать выполнение обработки последнего запущенного таска и/или последнего принятого ответа. Будет показательный пример.Я ухожу в отпуск, не обещаю что посмотрю. :-)
...
Рейтинг: 0 / 0
12.07.2012, 12:44
| Ответить | Цитировать | Написать  
[SL] Одна переменная для нескольких обработчиков
    #37876401
Фотография Алексей К
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Алексей К
Участник
enigmaticЕсли честно, меня терзают смутные сомнения, что у меня то же самое, но не на тасках =)Ничего удивительного. :-) Таски всего лиш более удобная реализация всем давно известных концепций. :-)
...
Рейтинг: 0 / 0
12.07.2012, 12:46
| Ответить | Цитировать | Написать  
[SL] Одна переменная для нескольких обработчиков
    #37876445
enigmatic
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
enigmatic
Участник
Алексей КНа каждый асинхронный вызов создаётся новый объект таска. Мы подписываемся на результат выполнения всех запущенных тасков, например, через ContinueWith. Может оказаться, что последний запущенный таск не будет последним выполненным. Типичная ситуация, master-detail. Может оказаться, что текущей записи в списке master будет показан detail "предыдущей текущей" записи в master.Хорошо, я все перепроверю.

Алексей КЯ ухожу в отпуск, не обещаю что посмотрю. :-)Приятного отдыха! :)
...
Рейтинг: 0 / 0
12.07.2012, 13:03
| Ответить | Цитировать | Написать  
15 сообщений из 40, страница 2 из 2
  2  все
Форумы / WPF, Silverlight [игнор отключен] [закрыт для гостей] / [SL] Одна переменная для нескольких обработчиков
Целевая тема:
Создать новую тему:
Автор:
Закрыть
Цитировать
Найденые пользователи ...
Разблокировать пользователей ...
Читали тему (0):
Читали форум (0):
Пользователи онлайн (0):
Польз. соглашение
NoSQL.ru       Новости, Чат       Фотоальбом: Участники, Встречи
Закрыть
start [/forum/topic.php?fid=21&gotonew=1&tid=1441749]:
 0ms
get settings:
 9ms
get forum list:
 12ms
check forum access:
 3ms
check topic access:
 3ms
track hit:
 37ms
get topic data:
 8ms
get first new msg:
 6ms
get forum data:
 2ms
get page messages:
 49ms
get tp. blocked users:
 1ms
others: 10ms
total:  140ms
созд. / загр.: 140ms
x
x
Закрыть


Просмотр
0 / 0
Close
Debug Console [Select Text]