Гость
Войти | Профиль | Очистить
Действия ...
Форумы / WinForms, .Net Framework [игнор отключен] [закрыт для гостей] / Как реализовать такую идею ? Есть ли готовые решения ? / 25 сообщений из 44, страница 1 из 2
  1  все
29.03.2019, 13:08
    #39793541
WaspNewCore
WaspNewCore
Гость
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Как реализовать такую идею ? Есть ли готовые решения ?
Задача такая:
В некий класс/сервис должны поступать задачи. В рамках задачи нужно работать с базой в рамках транзакции + вызовы к сторонним системам через HttpClient, в случае успеха выполнения которых нужно успешно закрывать транзакцию. При этом стоит требование об ограничении количества параллельно выполняющихся таких задач (тасков).

Соответственно по задумке, при поступлении задачи должен стартовать новый Task и что-то там делать. Общее количество работающих задач я планирую ограничить через семафор. Но сложность в том, чтобы реализовать следующее:
Нужно проконтролировать, что задачи при успешном И не успешном выполнении отчистят все ресурсы за собой: закроют соединение, освободят семафор, уберут ссылку на себя - чтобы не утекала память. На все время выполнения задачи ссылку на нее нужно где-то сохранять, чтобы сборщик мусора не убил, но затем эту ссылку нужно почистить.

Как такое можно реализовать ? Есть ли готовые решения ?
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
29.03.2019, 13:10
    #39793542
Roman Mejtes
Roman Mejtes
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Как реализовать такую идею ? Есть ли готовые решения ?
Используйте TaskScheduler
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
29.03.2019, 13:11
    #39793543
Roman Mejtes
Roman Mejtes
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Как реализовать такую идею ? Есть ли готовые решения ?
точнее реализуйте свой. который будет запускать таск, с ограничением на количество, очередью выполнения и прочим, прочим, прочим
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
29.03.2019, 13:13
    #39793544
WaspNewCore
WaspNewCore
Гость
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Как реализовать такую идею ? Есть ли готовые решения ?
Roman Mejtesточнее реализуйте свой. который будет запускать таск, с ограничением на количество, очередью выполнения и прочим, прочим, прочим

Про TaskScheduler не знал, спасибо, буду копать. А вот необходимость реализовывать "ограничением на количество, очередью выполнения и прочим, прочим, прочим" как раз смущает ) Этого я и хотел избежать.
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
29.03.2019, 14:16
    #39793595
Изопропил
Изопропил
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Как реализовать такую идею ? Есть ли готовые решения ?
WaspNewCoreЭтого я и хотел избежать
тогда программиста нанимать нужно
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
29.03.2019, 14:19
    #39793604
WaspNewCore
WaspNewCore
Гость
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Как реализовать такую идею ? Есть ли готовые решения ?
Изопропил,

Ищем, приходите на собеседование )
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
29.03.2019, 14:20
    #39793606
WaspNewCore
WaspNewCore
Гость
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Как реализовать такую идею ? Есть ли готовые решения ?
Насчет TaskScheduler я переборщил. Из головы вылетело про него. Обычно напрямую таски создаем через Task.Run.
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
29.03.2019, 14:43
    #39793632
Petro123
Petro123
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Как реализовать такую идею ? Есть ли готовые решения ?
WaspNewCoreбазой в рамках транзакции + вызовы к сторонним системам через HttpClient,читать про РАСПРЕДЕЛЕННЫЕ транзакции.
Дорогая штука.
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
29.03.2019, 14:52
    #39793639
Petro123
Petro123
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Как реализовать такую идею ? Есть ли готовые решения ?
WaspNewCore,
Код: c#
1.
System.Transactions
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
29.03.2019, 14:55
    #39793641
Petro123
Petro123
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Как реализовать такую идею ? Есть ли готовые решения ?
WaspNewCoreЭтого я и хотел избежать.дык у вас в ТЗ слова Ограничения/ограничить.)))
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
29.03.2019, 15:06
    #39793657
vb_sub
vb_sub
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Как реализовать такую идею ? Есть ли готовые решения ?
WaspNewCore,

в сторону pipeline- pattern смотрел?
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
29.03.2019, 15:08
    #39793663
WaspNewCore
WaspNewCore
Гость
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Как реализовать такую идею ? Есть ли готовые решения ?
Petro123WaspNewCoreбазой в рамках транзакции + вызовы к сторонним системам через HttpClient,читать про РАСПРЕДЕЛЕННЫЕ транзакции.
Дорогая штука.

Распределенные задачи не нужны !
Требуется чтобы созданный таск в рамках транзакции обрабатывал данные из бд. Запрашивал дополнительную информацию у стороннего сервиса, и успешно закрывал транзакцию после обработки. Либо падал с откатом транзакции, чтобы кто-то другой подхватил задачу и попробовал ее сделать.

Основная сложность, при поступлении задач, генерить таски не больше заданного одновременного количества (думаю через семафор), а также следить за тем, чтобы таски завершаясь освобождали ресурсы - тот же семафор. Соотвественно где-то хранить список текущих тасков, защищая их от сборщика мусора, и удалять завершенные.
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
29.03.2019, 15:11
    #39793667
WaspNewCore
WaspNewCore
Гость
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Как реализовать такую идею ? Есть ли готовые решения ?
vb_subWaspNewCore,

в сторону pipeline- pattern смотрел?

В первый раз слышу про него, это явно не классический от GOF. Почитаю, может придумаю как задействовать. Надеюсь это не просто producer-consumer..... Ой. Кстати. Может BlockingCollection поможет решить мою задачу, нужно подумать..
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
29.03.2019, 15:23
    #39793686
Petro123
Petro123
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Как реализовать такую идею ? Есть ли готовые решения ?
WaspNewCoreРаспределенные задачи не нужны !
Требуется чтобы созданный таск в рамках транзакции обрабатывал данные из бд. Запрашивал дополнительную информацию у стороннего сервиса, и успешно закрывал транзакциюможет в школу сходить?
Распределенные не задачи, я говорил, а транзакции.
Приводи пример уже что ли.
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
29.03.2019, 15:26
    #39793689
Petro123
Petro123
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Как реализовать такую идею ? Есть ли готовые решения ?
WaspNewCore,
Если без распределенных, то обычная очередь для того чтобы другой подхватил.
Транзакция будет одна в одном блоке try.
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
29.03.2019, 15:29
    #39793694
Petro123
Petro123
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Как реализовать такую идею ? Есть ли готовые решения ?
WaspNewCoreТребуется чтобы созданный таск в рамках транзакции обрабатывал данные из бд.все бд работают в рамках транзакции.
Комментируй.
Либо это лишние слова и ты просто читаешь из бд, и потом пишешь несколько операций одной транзакцией. Например 10 раз insert с откатом.
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
29.03.2019, 15:32
    #39793697
Petro123
Petro123
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Как реализовать такую идею ? Есть ли готовые решения ?
WaspNewCoreОбщее количество работающих задач я планирую ограничить через семафор.вместо пула потоков с maxPoolingThread?
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
29.03.2019, 15:42
    #39793706
WaspNewCore
WaspNewCore
Гость
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Как реализовать такую идею ? Есть ли готовые решения ?
Petro123,

Есть тонкость, которую я забыл упомянуть. Одновременно будет работать несколько таких сервисов, по обработке задач. Работать будут в одном приложении - в разных потоках. Поэтому ограничить через общий пул потоков не выйдет. Нужны индивидуальные настройки.
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
29.03.2019, 15:45
    #39793709
Petro123
Petro123
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Как реализовать такую идею ? Есть ли готовые решения ?
WaspNewCoreЕсть ли готовые решения ?
Код: c#
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
private Task MyAsync()
{
	return Task.Run(() =>
		{
			// код в потоке
                        ReadDB
                        ReadSiteWEB
                        InsertDB
			...
		}
		);
}

ButtonsClick()
{
	await MyAsync();
}


Что по ТЗ упустил?
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
29.03.2019, 15:47
    #39793712
Petro123
Petro123
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Как реализовать такую идею ? Есть ли готовые решения ?
WaspNewCoreнесколько таких сервисовпереведи. Зачем?
У тебя и от одного сервиса весь проц будет занят.
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
29.03.2019, 15:48
    #39793714
Petro123
Petro123
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Как реализовать такую идею ? Есть ли готовые решения ?
WaspNewCoreобщий пул потоковон общий вроде на процесс
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
29.03.2019, 15:50
    #39793718
Petro123
Petro123
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Как реализовать такую идею ? Есть ли готовые решения ?
WaspNewCore,
Задача равно поток. И не усложняй жизнь семафорами.
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
29.03.2019, 15:56
    #39793720
vb_sub
vb_sub
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Как реализовать такую идею ? Есть ли готовые решения ?
WaspNewCore, зачем ограничивать общее количество работающих задач?
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
29.03.2019, 16:00
    #39793727
Petro123
Petro123
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Как реализовать такую идею ? Есть ли готовые решения ?
vb_subWaspNewCore, зачем ограничивать общее количество работающих задач?+1
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
29.03.2019, 16:55
    #39793768
WaspNewCore
WaspNewCore
Гость
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Как реализовать такую идею ? Есть ли готовые решения ?
Petro123,

Упущено ограничение на одновременную работу не более заданного числа.

Т.е. должно быть примерно так:

Код: c#
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
Service
   RunWork ()
  {
        var semaphore = new SemaphoreSlim (maxCount)
        while (...)
        {
          var item = GetNextWorkItem ();
          Task currentWork = Task.Run (item...)
          
          и вот дальше  нужно сохранить ссылку на задачу,чтобы сборщик мусора не убрал. а когда таск завершится, 
          чтобы он сделал semaphore.Release() и удалит ссылку на себя, позволив сборщику мусора убрать за собой

          и при этом учесть вероятность, что таск может упасть, и должен тоже успеть вызвать semaphore.Release()
        }
  }
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
  1  все
Форумы / WinForms, .Net Framework [игнор отключен] [закрыт для гостей] / Как реализовать такую идею ? Есть ли готовые решения ? / 25 сообщений из 44, страница 1 из 2
Целевая тема:
Создать новую тему:
Автор:
Найденые пользователи ...
Разблокировать пользователей ...
Читали тему (0):
Читали форум (0):
Пользователи онлайн (0):
Польз. соглашение
созд. / загр.: 493ms
Закрыть
start [/forum/topic.php?fid=20&mobile=1&tid=1399031]:
 0ms
get settings:
 10ms
get forum list:
 13ms
check forum access:
 3ms
check topic access:
 3ms
track hit:
 126ms
get topic data:
 12ms
get forum data:
 2ms
get page messages:
 59ms
get tp. blocked users:
 1ms
others: 264ms
total:  493ms
x
x
Закрыть


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