чувак спрашивал про таски

я думаю, что ему надо читать в лупе и никакой приемник ему вообще не нужен

вы понаписали слов непонятных, чето я ваще потерялся((

@maxvell2010 можно просто по сообщению создавать задачу и забывать про неё?

не

обрабатывающий опток обрабатывает не столько сами письма, сколько тех кому они будут отправлены

и что?

//Код обработчика: While(true){ hasNewLetters.WaitOne(); hasNewLetters.Reset(); while(lettersQueue.count>1) { Letter letter = null if(!lettersQueue.TryDeque(out letter) continue; Handle(Letter); } } //Код приёмки: While(true){ var newLetter = MailService.Receive(); lettesQueue.Enqeue(newLetter); hasNewLetters.Set(); }

С тебя пиво

Зашел в телегу. В чяти 750+ сообщений

С тебя пиво

ты погоди.. ща он как вставит это и скажет что у него приемник не запускается

Чотут у вас?

//Код обработчика: While(true){ hasNewLetters.WaitOne(); hasNewLetters.Reset(); while(lettersQueue.count>1) { Letter letter = null if(!lettersQueue.TryDeque(out letter) continue; Handle(Letter); } } //Код приёмки: While(true){ var newLetter = MailService.Receive(); lettesQueue.Enqeue(newLetter); hasNewLetters.Set(); }

это не жыза в 2017 году

ты погоди.. ща он как вставит это и скажет что у него приемник не запускается

Тогда будет ещё одно пиво-))

Чотут у вас?

Макса на пиво разводим

это не жыза в 2017 году

да.. вариант через concurrentQueue самый православный. но на безрыбье и рак рыба

это не жыза в 2017 году

Хипстор детектед. Парень, который спрашивает, не в курсах про новую моду. А этот олдскул должен от зубов отскакивать если ты касаешься async await

так я до сих пор не понел, что он делает. чому нельзя например, на каждое сообщение из почты шедулилть таску со всей логикой "обработчика"?

//Код обработчика: While(true){ hasNewLetters.WaitOne(); hasNewLetters.Reset(); while(lettersQueue.count>1) { Letter letter = null if(!lettersQueue.TryDeque(out letter) continue; Handle(Letter); } } //Код приёмки: While(true){ var newLetter = MailService.Receive(); lettesQueue.Enqeue(newLetter); hasNewLetters.Set(); }

я просто маленько не догоняю, получаеться один цикл отрабатывает, начинает рбаоту второй цикл который запускает первый

да.. вариант через concurrentQueue самый православный. но на безрыбье и рак рыба

Без concurent вообще никак. (только с локом, но это пиздец -)

я просто маленько не догоняю, получаеться один цикл отрабатывает, начинает рбаоту второй цикл который запускает первый

Неее - это код двух твоих потоков. Ты же говорил что у тебя два потока, верно?

да

Неее - это код двух твоих потоков. Ты же говорил что у тебя два потока, верно?

хахах, ну я как в воду глядел ;)

хахах, ну я как в воду глядел ;)

так что второе пиво мне!

Неее - это код двух твоих потоков. Ты же говорил что у тебя два потока, верно?

Второй цикл крутится постоянно и постоянно наполняет очередь сообщений. А первый фрагмень крутится в другом потоке и постоянно ждёт наполнения этой очереди

так я до сих пор не понел, что он делает. чому нельзя например, на каждое сообщение из почты шедулилть таску со всей логикой "обработчика"?

хз, может аккумулировать нужно.. ?

Макса на пиво разводим

Мы тут с четверга лудим. Карнавал. А еще и завтра

так что второе пиво мне!

a deal

Второй цикл крутится постоянно и постоянно наполняет очередь сообщений. А первый фрагмень крутится в другом потоке и постоянно ждёт наполнения этой очереди

вроде понял, щас буду пробовать сделать, спасибо

хз, может аккумулировать нужно.. ?

вот для аккумулирования конкурентные коллекции - 10 из 10.

так я до сих пор не понел, что он делает. чому нельзя например, на каждое сообщение из почты шедулилть таску со всей логикой "обработчика"?

Проблема начинается в "шедулить таску"

батмансы. я ведь до сих пор не понел, чо он делает. "шлёт из потока в поток сообщеньки" своими странными методами - мне ничо не говорит

пишет в коллекцию и на ней же ждет, не?

конкурент кью не даёт ждать на коллекции. она сразу провалится если пустая. Поправь если я не прав

мне кажется Максу вот что нужно: 1. читать почту 2. закидывать письма в канкарент кью 2.1. проверять тут же канкарент кью - если там все ок, накопилось - тут же таску и обработку - если не накопилось - ну ничего, скоро накопится

а что если Макс нам не может объяснить все как есть, потому что там NDA? и ему приходится вот так запутанно просить у нас помощи?

ну а я другое считаю) и пока макс не выдаст нормальное описание и ограничения типо "код приёмника не мой" - это всё лел

блин, чёто я ржу прямо в голос

а что если Макс нам не может объяснить все как есть, потому что там NDA? и ему приходится вот так запутанно просить у нас помощи?

>NDA Заорал

вы заебали, какие то понятия пишете я даже не ебу что это, NDA

вроде понял, щас буду пробовать сделать, спасибо

Макс - мы правильно поняли твою таску: "есть два работника. Одиин принимает почту и кладёт её на склад, второй забирает всё со склада и что то с этими посылками делает. Всё происходит одновременно" ?

это что?

д

это что?

non disclosure agreement

да

вы заебали, какие то понятия пишете я даже не ебу что это, NDA

Договор о неразглашение.

Макс - мы правильно поняли твою таску: "есть два работника. Одиин принимает почту и кладёт её на склад, второй забирает всё со склада и что то с этими посылками делает. Всё происходит одновременно" ?

щас все происходит по очереди я хочу сделать одновременно

вы заебали, какие то понятия пишете я даже не ебу что это, NDA

Макс. Ребята просто забыли как были джуниорами. Всё ровно.

из того кода что они написали я нихуя не понял, ток саму идею уловил))

Макс. Ребята просто забыли как были джуниорами. Всё ровно.

да не забыли мы. просто без контекста насоветуем сейчас не того..

@maxvell2010 а если мы сделаем все одновременно и без приёмника?

@maxvell2010 а если мы сделаем все одновременно и без приёмника?

на делегатах и ивентах

канкарент кью что это блять

канкарент кью что это блять

Макс - гугл

канкарент кью что это блять

queue - очередь concurrentqueue - потокобезопасная очередь это такие вот штуки в дотнете есть замечательные

ну щас так и будет

буду сидеть гуглить

@maxvell2010 а если мы сделаем все одновременно и без приёмника?

я не выйдет

чому

канкарент кью что это блять

ConcurentQueue. Ты не можешь использовать List или другие обычные коллекции при межпотоковом взаимодействие. Тебе нужно разобраться в этом а не агрится, иначе стрельнёшь в ногу себе.

я не выйдет

приемник не просто принимает, ибо письма приходят ток с адресатом и с само письмо, а приемник получается много других данных о письме которые нужны

и что

ConcurentQueue. Ты не можешь использовать List или другие обычные коллекции при межпотоковом взаимодействие. Тебе нужно разобраться в этом а не агрится, иначе стрельнёшь в ногу себе.

ну почму.. он может, если постигнет локи, мьютексы, семафоры и вот это все но с concurrentQueue проще ;)

ну почму.. он может, если постигнет локи, мьютексы, семафоры и вот это все но с concurrentQueue проще ;)

И будет уволен после первого дедлока-)))

и что

ну приемник отсеивает спамные письма например, что бы не грузит обработчик лишний раз

ConcurentQueue. Ты не можешь использовать List или другие обычные коллекции при межпотоковом взаимодействие. Тебе нужно разобраться в этом а не агрится, иначе стрельнёшь в ногу себе.

ну вот щас я это понял

ERROR: S client not available

приемник не просто принимает, ибо письма приходят ток с адресатом и с само письмо, а приемник получается много других данных о письме которые нужны

кароче тебе не надо никаких синков ничего. это реально делается на тасках влоб

я думал просто можно как то... но увы((

ну вот щас я это понял

Всё равно придётся идти в гуглу чтобы понять что можно что нельзя и почему.

ну приемник отсеивает спамные письма например, что бы не грузит обработчик лишний раз

ну так пусть отсеивает! фигачь таски, асинхронно делай свои дела там нужные

кароче тебе не надо никаких синков ничего. это реально делается на тасках влоб

Давай код

Давай код

давай уже ID сессии тимвьювера и пароль, ща поможем

Неее

кароче из всего я понял одно, так как я думал сделать, сделат ьне получиться, надо делать чуток подругмоу))

мне интересно как ты с тасками сделаешь это

ну тока псевдокод, раз он либу не назвал

ну тока псевдокод, раз он либу не назвал

Как я написал так и ты напиши

конечно псевдо

сейчас примерно так и работает как написал @tmteam простто эти 2 цикла в одном больше цикле и херачат поочередно

мне интересно как ты с тасками сделаешь это

ну на получение - цикл дальше обработка - таски

лан спс всем за помощ больше))

ну на получение - цикл дальше обработка - таски

А если нужно чтобы обработка была строго последовательной?

лан спс всем за помощ больше))

Удачи

А если нужно чтобы обработка была строго последовательной?

а об этом в задаче не говорилось :)

а об этом в задаче не говорилось :)

А у вас нет трудового договора на руках

</joke>

лан спс всем за помощ больше))

погоди! уточни условия! а то мы тебе кажись не то насоветовали

погоди! уточни условия! а то мы тебе кажись не то насоветовали

Уже уточнили три раза же

Уже уточнили три раза же

ну про последовательность ты хорошо подметил ;) а то я в 4 утра уже хреново соображаю

а об этом в задаче не говорилось :)

Тут делается простой вывод. Мы не знаем скорость обработки писем и скорость приёма. Если скорость приёма больше скорости обработки - то ты устроишь пул экзост

В случае с конкуренткью - ты просто можешь проверить что count> max, и что то там сделать

В случае с конкуренткью - ты просто можешь проверить что count> max, и что то там сделать

ну тут соглашусь, да. некий backpressure реализовать

откидывать при переполнении или что то там еще придумать

или в сеть гнать куда-то и на другой машине обрабатывать

откидывать при переполнении или что то там еще придумать

угу. У меня эта беда на каждом шагу. Потому таски использую крайне редко

или в сеть гнать куда-то и на другой машине обрабатывать

Дааа. Даже можно хендлинг сообщений на шину кинуть...ММММ красота...

можно притащить акку

за ней скалу ;)