Archief - C# Vermoedelijk threading probleem

[COLOR="DarkOrange"][DllImport("user32.dll", EntryPoint = "DestroyIcon")]
static extern int DestroyIcon(IntPtr hIcon);[/COLOR]

static void Refresh(object sender, System.Timers.ElapsedEventArgs e)
{
	Bitmap b = (Bitmap)basicIcon.Clone();
	Graphics g = Graphics.FromImage(b);

	avg.Update();

	// draw yellow bars
	if (avg.Get > 1) g.FillRectangle(Brushes.LawnGreen, 1, 11, 2, 2);
	if (avg.Get > maxSpeed * .07) g.FillRectangle(Brushes.LawnGreen, 4, 9, 2, 4);
	if (avg.Get > maxSpeed * .17) g.FillRectangle(Brushes.LawnGreen, 7, 7, 2, 6);
	if (avg.Get > maxSpeed * .45) g.FillRectangle(Brushes.LawnGreen, 10, 5, 2, 8);
	if (avg.Get > maxSpeed * .85) g.FillRectangle(Brushes.LawnGreen, 13, 3, 2, 10);

	// update icon
	IntPtr handle = b.GetHicon();
	trayIcon.Icon = Icon.FromHandle(handle);
	trayIcon.Text = string.Format("{0} KB/s", avg.Get);

	// update form
	//Debug.WriteLine(speedForm.InvokeRequired.ToString());
	speedForm.SpeedBar.Value = (int)Math.Min(avg.Get, speedForm.SpeedBar.Maximum);
	speedForm.lblSpeed.Text = string.Format("{0} KB/s", avg.Get);

	// clean
	[COLOR="DarkOrange"]DestroyIcon(handle);[/COLOR]
	b.Dispose();
	g.Dispose();
	//GC.Collect();
}

private static IObservable<double> deltaBytes;

deltaBytes = Observable.Timer(DateTimeOffset.Now, TimeSpan.FromSeconds(1))
                                 .Select(x => GetBytesReceivedDelta())
                                 .Buffer(3)
                                 .Select(x => x.Average());

deltaBytes.Subscribe(RefreshAvg);

static void RefreshAvg(double average)
{
   Bitmap b = (Bitmap)basicIcon.Clone()
   ....
}

      static void frmToolWindow_Load(object sender, EventArgs e)
      {
         deltaBytes.ObserveOn(SynchronizationContext.Current)
                   .SubscribeOn(SynchronizationContext.Current)
                   .Subscribe(avg =>
                     {
                        frmToolWindow.SpeedBar.Value = Math.Min((int)avg, frmToolWindow.SpeedBar.Maximum);
                        frmToolWindow.Text = string.Format(RECEIVING_TEXT, Math.Round(avg, 1));
                     });
      }

var index = (int)((average * 100 / maxSpeed) / (100 / 5));

       [STAThread]
      static void Main()
      {
         #region Initialize notify icon (system tray icon)
         trayIcon = new NotifyIcon();
         trayIcon.Text = string.Format(RECEIVING_TEXT, 0);
         trayIcon.ContextMenu = new ContextMenu(new MenuItem[] {new MenuItem("Receiving", ChangeView), new MenuItem("Sending", ChangeView), new MenuItem("-"), new MenuItem("Exit", ExitApplication)});
         trayIcon.ContextMenu.MenuItems[0].RadioCheck = true;
         trayIcon.ContextMenu.MenuItems[1].RadioCheck = true;
         trayIcon.ContextMenu.MenuItems[0].Checked = true;
         trayIcon.DoubleClick += (_, __) => frmToolWindow.Visible = !frmToolWindow.Visible;
         trayIcon.Icon = Properties.Resources.speedmeter;
         trayIcon.Visible = true;
         #endregion;

         basicIcon = Properties.Resources.Meterke;
       
         var bufferCount = 3;

         var deltaBytes = Observable.Timer(DateTimeOffset.Now, TimeSpan.FromMilliseconds(1000 / bufferCount))
                                 .Select(x => GetBytesReceivedDelta())
                                 .Buffer(bufferCount)
                                 .Select(x => x.Average());

         frmToolWindow = new ToolWindow(deltaBytes, maxSpeed);

         deltaBytes.Subscribe(RefreshAvg);

         Application.Run();
      }

      public static double GetBytesReceivedDelta()
      {
         return rand.Next(0, maxSpeed);           //Todo calc delta
      }

      static void RefreshAvg(double average)
      {
         var index = (int)((average * 100 / maxSpeed) / (100 / 5));

         var iconSetRect = new Rectangle(1, 1 + (24 * index), 22, 22);

         using (var b = basicIcon.Clone(iconSetRect, basicIcon.PixelFormat))
         {
            // update icon
            trayIcon.Icon = Icon.FromHandle(b.GetHicon());
            trayIcon.Text = string.Format(RECEIVING_TEXT, Math.Round(average, 1));    
         }
      }

      static void ChangeView(object sender, EventArgs e)
      {
         trayIcon.ContextMenu.MenuItems[0].Checked = (sender == trayIcon.ContextMenu.MenuItems[0]);
         trayIcon.ContextMenu.MenuItems[1].Checked = (sender == trayIcon.ContextMenu.MenuItems[1]);
         //Debug.WriteLine(((MenuItem)sender).Text);
         // ... todo
      }

      static void ExitApplication(object sender, EventArgs e)
      {
         Application.Exit();
         trayIcon.Dispose();
      }
   }

     public partial class ToolWindow : Form
    {
        public ToolWindow(IObservable<double> deltaBytes, int max)
        {
            InitializeComponent();

            this.SpeedBar.Maximum = max;

            // manually set the form's location
            Location = new Point(Screen.PrimaryScreen.Bounds.Width - Width - 120, Screen.PrimaryScreen.Bounds.Height - Height - 100);

            this.Load += (_, __) =>
            {
                deltaBytes.ObserveOn(SynchronizationContext.Current)
                          .SubscribeOn(SynchronizationContext.Current)
                          .Subscribe(avg =>
                            {
                                SpeedBar.Value = Math.Min((int)avg, SpeedBar.Maximum);
                                Text = string.Format(Program.RECEIVING_TEXT, Math.Round(avg, 1));
                            });
            };
        }
        
        private void SpeedForm_FormClosing(object sender, FormClosingEventArgs e)
        {
            // cancel exiting application when form is closed
            if (e.CloseReason == CloseReason.UserClosing)
            {
                e.Cancel = true;
                this.Visible = false;
            }
        }
    }