c# - Not every result of IProgress<int> comes out of the task -


consider following implementation, method accepts iprogress<int>, iterates on 10000 objects. numbers array variable returns 10000 objects, iprogress<int> reports between 9970 - 9980 objects. varies per run, "lost".

    protected async override task<int[]> collectdataasyncimpl(iprogress<int> progress) {                         return await task.run<int[]>(() => {              var numbers = new list<int>();              foreach (var idx in new int32range(1, 10000).asenumerable().index()) {                                                              numbers.add(idx.value);                                      if (progress != null) {                     progress.report(idx.value);                 }              }              return numbers.toarray();         });     }

as reference, here's test ran. fails @ third assert assert.equal(10000, result[9999]);.

[fact] async void reportsprogress() {                 var sut = new integercollector();     var result = new list<int>();     var output = await sut.collectdataasync(new progress<int>(i => result.add(i)));     assert.equal(10000, output.length);     assert.equal(1, result[0]);     assert.equal(10000, result[9999]); }

clearly i'm doing wrong, or don't understand internals of task/threading. implementation of iprogress<int> new progress<int>(i => result.add(i)) not correct? should make thread safe, , if so, how do that?

github has code can clone & test if need be: https://github.com/kodefoxx/kf.datacollection/tree/master/source/kf.datacollection

it because of how progress<t> implemented. when created, progress<t> captures synchronization context , uses execute i => result.add(i). since running test, assume there no synchronization context. in case progress<t> uses default synchronizationcontext, posts work items thread pool (threadpool.queueuserworkitem). task completes before thread pool processes queued items, , explains results inconsistency.

a simple way check if case: change iprogress<int> argument action<int> , pass i => result.add(i) delegate directly, without wrapping progress<t>.


Comments

Post a Comment

Popular posts from this blog

resizing Telegram inline keyboard -

telegram's inline keyboard great feature lots of different use cases. inline buttons added list of items this: inline_keyboard = [[inlinekeyboardbutton(text="button", callback_data="button"), inlinekeyboardbutton(text="reset",callback_data="reset")]] inline_keyboard_markup = inlinekeyboardmarkup(inline_keyboard) update.message.reply_text("hi", reply_markup=inline_keyboard_markup) the above code adds 2 buttons each half width of chat screen. i know the normal keyboard button there resize_keyboard parameter somehow can used. my question is there way resize inline buttons ? example make full width or quarter width. unfortunately, can't now. :( you can suggest @botsupport , might add feature next version.
Read more

javascript - How to bind ViewModel Store to View? -

i'm pretty new ext js , trying embed multiselect inside panel . the viewmodel has stores property can see here: ext.define('test.view.controls.search.searchfiltermodel', { extend: 'ext.app.viewmodel', alias: 'viewmodel.filter', data: { title: '' }, stores: { test: { fields: [ 'id', 'name' ], proxy: { type: 'ajax', url: 'api/test', reader: 'array' }, autoload: true } } }); i bind in view this: viewmodel: { type: 'filter' }, layout: 'fit', border: 1, plain: true, scrollable: 'y', layout: 'fit', bind: { title: '{title}', }, items: { xtype: 'multiselect', scrollable: false, allowblank: true, ddreorder: true, bind: { store: '{test}' }, valuefield: 'id', displayfield: 'name' } ...
Read more

python - Alternative to referencing variable before assignment -

import time # define variables username = "username" password = "password" customer_info_file_path = "c:\\users\megam\pycharmprojects\general stuff\the square pie co\customer " \ "information\{}.txt ".format(name) username_entry = input("enter username\n>>") password_entry = input("enter password\n>>") if username_entry != username or password_entry != password: print("access denied\nyou have entered username or password incorrectly. please check password , " "account name , try again.\n") else: print("access granted") choice_menu = input("\na) view list of customers\nb) add customer\nc) delete customer\nd) log out\n>>") if choice_menu == "a": customer_info = open(customer_info_file_path, 'a', ) file = open(customer_info_file_path, 'r') output = file.read() ...
Read more