Как я могу постоянно обновлять свой ListBox синхронно

Question

Я вычисление простых чисел м.т. два чисел, используя следующий код

private static IEnumerable<int> GetPrimes(int from, int to) 
    { 
     for (int i = from; i <= to; i++) 
     { 
      bool isPrime = true; 
      int limit = (int)Math.Sqrt(i); 
      for (int j = 2; j <= limit; j++) 
       if (i % j == 0) 
       { 
        isPrime = false; 
        break; 
       } 
      if (isPrime) 
      { 
       yield return i; 
      } 
     }  
    } 

И я хочу, чтобы обновить окно списка без блокировки моего UI нити, все простые числа, используя выше код. Согласие, которое я использую как следующее, но это не работает.

public MainWindow() 
    { 
     InitializeComponent(); 
     _worker = new BackgroundWorker(); 
     _worker.DoWork += _worker_DoWork; 
     this.DataContext = this; 

    } 

    private void _worker_DoWork(object sender, DoWorkEventArgs e) 
    { 
     PrimeNumbers = new ObservableCollection<int>(); 
     foreach (var item in GetPrimes(1, 10000000)) 
     {    
      Dispatcher.BeginInvoke(new Action<int>(Test), item); 
     }    
    } 

    private void Test(int obj) 
    { 
     PrimeNumbers.Add(obj); 
    } 

public ObservableCollection<int> PrimeNumbers 
    { 
     get 
     { 
      return primeNumbers; 
     } 
     set 
     { 
      primeNumbers = value; 
      OnPropertyChanged("PrimeNumbers"); 

     } 
    } 

private void Button_Click_1(object sender, RoutedEventArgs e) 
    { 
     _worker.RunWorkerAsync(); 
    } 

но этот подход замораживает мой интерфейс. Я хочу, чтобы иметь результат непрерывно идущий от метода GetPrimes и продолжайте добавлять к моему listboz

Answer 1

Вы просто проводки слишком много. Этот код работает так, как ожидалось:

public partial class MainWindow 
{ 
    public ObservableCollection<int> PrimeNumbers { get; set; } 

    public MainWindow() 
    { 
     InitializeComponent(); 
     PrimeNumbers = new ObservableCollection<int>(); 
    } 

    private void Button_Click(object sender, System.Windows.RoutedEventArgs e) 
    { 
     PrintPrimes(PrimeNumbers.Add, 1, 10000000, SynchronizationContext.Current); 
    } 

    private static void PrintPrimes(Action<int> action, int from, int to, 
            SynchronizationContext syncContext) 
    { 
     Task.Run(() => 
     { 
      for (var i = from; i <= to; i++) 
      { 
       var isPrime = true; 
       var limit = (int) Math.Sqrt(i); 
       for (var j = 2; j <= limit; j++) 
       { 
        if (i%j == 0) 
        { 
         isPrime = false; 
         break; 
        } 
       } 
       if (isPrime) 
       { 
        syncContext.Post(state => action((int)state), i); 
        Thread.Sleep(1); 
       } 
      } 
     }); 
    } 
} 

Рассмотрите возможность избежать использования старого класса BackgroundWorker. Кроме того, вместо использования механизма синхронизации вашей платформы попробуйте переключиться на независимую платформу SynchronizationContext.

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

public partial class MainWindow 
{ 
    public ObservableCollection<int> PrimeNumbers { get; set; } 

    public MainWindow() 
    { 
     InitializeComponent(); 
     PrimeNumbers = new ObservableCollection<int>(); 
    } 

    private void Button_Click(object sender, System.Windows.RoutedEventArgs e) 
    { 
     PrintPrimes(items => items.ForEach(PrimeNumbers.Add), 
        1, 10000000, SynchronizationContext.Current); 
    } 

    private static void PrintPrimes(Action<List<int>> action, int from, int to, 
            SynchronizationContext syncContext) 
    { 
     Task.Run(() => 
     { 
      var primesBuffer = new List<int>(); 
      for (var i = from; i <= to; i++) 
      { 
       var isPrime = true; 
       var limit = (int) Math.Sqrt(i); 
       for (var j = 2; j <= limit; j++) 
       { 
        if (i%j == 0) 
        { 
         isPrime = false; 
         break; 
        } 
       } 
       if (isPrime) 
       { 
        primesBuffer.Add(i); 
        if (primesBuffer.Count >= 1000) 
        { 
         syncContext.Post(state => action((List<int>) state), 
             primesBuffer.ToList()); 
         primesBuffer.Clear(); 
        } 
       } 
      } 
     }); 
    } 
} 

Вы можете использовать Thread вместо Task.Run, если вы застряли с более старыми версиями рамок.

Answer 2

Этот код выглядит нормально, вы просто забыли начала ваш фон рабочего по телефону BackgroundWorker.RunWorkerAsync.

PrimeNumbers = new ObservableCollection<int>(); 

Эта строка должна находиться за пределами вашего рабочего (или быть вызвана в потоке пользовательского интерфейса).

Answer 3

Похоже, что мой пользовательский интерфейс очень часто обрабатывался, поэтому я использовал задержку в 1 секунду на моей рабочей рабочей ветке. Это помогло мне достичь моей функциональность

частных недействительного _worker_DoWork (объект отправителя, DoWorkEventArgs е) {

 foreach (var item in GetPrimes(1, 1000000)) 
     { 
      Thread.Sleep(1000); 
      Dispatcher.BeginInvoke(new Action<int>(Test), item); 
     }    
    }