using ...;
namespace Ping_test
{
public delegate void Del(string str);
public partial class Form1 : Form
{
public Form1()
{
InitializeComponent();
Del Call = new Del(UpdateRes);
}
private void button1_Click(object sender, EventArgs e)
{
new PingExample().Start( "192.168.1.1",10);
}
}
public class PingExample
{
private int Count = 0;
private int Cycle = 0;
private string ip = string.Empty;
public PingExample()
{
TTimer = new System.Threading.Timer(new TimerCallback(OnTimer), TimerRun, System.Threading.Timeout.Infinite, 1000);
}
public void Start(string ip_str, int Raz)
{
Count = 1;
Cycle = Raz;
ip = ip_str;
TTimer.Change(0, 1000);
}
private void OnTimer(object state)
{
if (Count <= Cycle)
{
Go();
}
}
public void Go()
{
AutoResetEvent waiter = new AutoResetEvent(false);
Ping pingSender = new Ping();
pingSender.PingCompleted += new PingCompletedEventHandler(PingCompletedCallback);
string data = "ID:<" + String.Format(@"{0,5:d}", Count.ToString()) + ">**********************";
byte[] buffer = Encoding.ASCII.GetBytes(data);
int timeout = 1000;
PingOptions options = new PingOptions(64, true);
pingSender.SendAsync(ip, timeout, buffer, options, waiter);
}
private void PingCompletedCallback(object sender, PingCompletedEventArgs e)
{
// If the operation was canceled, display a message to the user.
if (e.Cancelled)
{
Console.WriteLine("Ping canceled.");
((AutoResetEvent)e.UserState).Set();
}
if (e.Error != null)
{
Console.WriteLine("#" + Count.ToString() + " " + ip + " Ping failed: ");
Console.WriteLine(e.Error.ToString());
((AutoResetEvent)e.UserState).Set();
}
PingReply reply = e.Reply;
DisplayReply(reply);
((AutoResetEvent)e.UserState).Set();
Count++;
}
public void DisplayReply(PingReply reply)
{
if (reply == null)
return;
string Num = "#" + String.Format(@"{0,5:d}", Count.ToString());
if (reply.Status == IPStatus.Success)
{
string res = Num + " " + reply.Address.ToString() + " RTT " + reply.RoundtripTime.ToString() + " TTL " + reply.Options.Ttl.ToString() + " BUFFER " + reply.Buffer.Length.ToString();
res += " \"" + System.Text.ASCIIEncoding.ASCII.GetString(reply.Buffer) + "\"";
SendStr(res);
}
else
{
string res = Num + " " + ip + " ERROR: " + reply.Status.ToString();
SendStr(res);
}
}
void SendStr(string str);
{
}
}
backgroundWorker.DoWork += (sender, e) => { ... };
backgroundWorker.DoWork += delegate { ... };// some background thread code
Form1.Dispatcher.Invoke(DispatcherPriority.ContextIdle, new Action(delegate()
{
label1.Content="invoked from background thread";
}));pingSender.PingCompleted += new PingCompletedEventHandler(PingCompletedCallback);
SynchronizationContext uiContext = SynchronizationContext.Current;
Thread thread = new Thread(Run);
// Запустим поток и установим ему контекст синхронизации,
// таким образом этот поток сможет обновлять UI
thread.Start(uiContext);private void Run(object state)
{
// вытащим контекст синхронизации из state'а
SynchronizationContext uiContext = state as SynchronizationContext;
// говорим что в UI потоке нужно выполнить метод UpdateUI
// и передать ему в качестве аргумента строку
uiContext.Post(UpdateUI, "Hello world!");
}/// <summary>
/// Этот метод исполняется в основном UI потоке
/// </summary>
private void UpdateUI(object state)
{
sampleListBox.Items.Add((string)state);
}