using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
namespace Listener
{
  /// <summary>
  /// 回調(diào)接口（類(lèi)似Listener）
  /// </summary>
  public interface ICallBackListener
  {
    void onCallBack();
    bool onCallBack(string pWhat);
  }

  /// <summary>
  /// 控制器類(lèi)，處理事務(wù)
  /// </summary>
  public class Controller
  {
    // 執(zhí)行任務(wù)的線程
    private Thread mThread;

    // 控制循環(huán)和控制是否處理的Flag
    private bool mFlagWhile;
    private bool mFlagDoWork;

    // 接收訂閱Listener的回調(diào)的集合(Android中的vector)
    private List<ICallBackListener> mListenerList;

    public Controller()
    {
      // 初始化Listener集合
      mListenerList = new List<ICallBackListener>();

      // 初始化線程相關(guān)
      mThread = new Thread(work);
      mFlagWhile = true;
      mFlagDoWork = true;
    }

    /// <summary>
    /// 具體執(zhí)行的工作
    /// </summary>
    private void work()
    {
      while (mFlagWhile)
      {
        Thread.Sleep(3000);
        if (mFlagDoWork)
        {
          // 執(zhí)行相應(yīng)的處理
          // 具體處理的工作就在這里
          ActiveOnCallBack();
        }
        Thread.Sleep(3000);
        if (mFlagDoWork)
        {
          // 執(zhí)行相應(yīng)的處理
          // 具體處理的工作就在這里
          ActiveOnCallBack("Test");
        }
      }
    }
    /// <summary>
    /// 啟動(dòng)Controller處理
    /// </summary>
    public void Start()
    {
      if (mFlagWhile)
        mThread.Start();
    }

    /// <summary>
    /// 關(guān)閉Controller處理
    /// </summary>
    public void Stop()
    {
      mFlagWhile = false;
      mFlagDoWork = false;
      mThread.Abort();
    }

    /// <summary>
    /// 激活onCallBack()
    /// </summary>
    private void ActiveOnCallBack()
    {
      if(mListenerList!=null)
        foreach (ICallBackListener tCallBack in mListenerList)
        {
          tCallBack.onCallBack();
        }
    }
    /// <summary>
    /// 激活onCallBack(string)
    /// </summary>
    /// <param name="pWhat">傳入的參數(shù)</param>
    private void ActiveOnCallBack(string pWhat)
    {
      if (mListenerList != null)
        foreach (ICallBackListener tCallBack in mListenerList)
        {
          tCallBack.onCallBack(pWhat);
        }
    }
    /// <summary>
    /// 設(shè)置Listener
    /// </summary>
    /// <param name="pCallBackListener">繼承ICallbackListener接口的類(lèi)</param>
    public void setOnListener(ICallBackListener pCallBackListener)
    {
      if (pCallBackListener != null)
        mListenerList.Add(pCallBackListener);
    }
    /// <summary>
    /// 移除Listener
    /// </summary>
    /// <param name="pCallBackListener">繼承ICallbackListener接口的類(lèi)</param>
    public void removeOnListener(ICallBackListener pCallBackListener)
    {
      if (pCallBackListener != null)
        mListenerList.Remove(pCallBackListener);
    }
  }
}

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using Listener;

namespace EventTest
{
  // Form一定要繼承ICallBackListener并實(shí)現(xiàn)其方法
  public partial class FormTest : Form, ICallBackListener
  {
    // UI更新委托
    private delegate void DelegateTextBox(string pString);

    // 控制器
    private Controller mController;

    public FormTest()
    {
      InitializeComponent();
    }

    private void Form1_Load(object sender, EventArgs e)
    {
      // 初始化控制器，設(shè)置偵聽(tīng)，并開(kāi)始
      mController = new Controller();
      mController.setOnListener(this);
      mController.Start();
    }

    // Override 接口實(shí)現(xiàn)
    public void onCallBack()
    {
      // 線程安全處理
      if (InvokeRequired)
      {
        textBox1.Invoke(new DelegateTextBox(pushTextInTextbox), new object[] { null });
      }
    }

    // Override 接口實(shí)現(xiàn)
    public bool onCallBack(string pWhat)
    {
      // 線程安全處理
      if (InvokeRequired)
      {
        textBox1.Invoke(new DelegateTextBox(pushTextInTextbox), new object[] { pWhat });
      }
      return false;
    }

    private void button1_Click(object sender, EventArgs e)
    {
      // 停止控制器
      mController.Stop();
    }

    /// <summary>
    /// 接收委托的方法，該方法通過(guò)Invoke控制UI
    /// </summary>
    /// <param name="pText">傳入的string參數(shù)</param>
    private void pushTextInTextbox(string pText)
    {
      if (pText != null)
      {
        textBox1.Text += "\n當(dāng)前的處理：" + pText;
      }
      else
      {
        textBox1.Text += "\n空消息！";
      }
    }

    private void Form1_FormClosing(object sender, FormClosingEventArgs e)
    {
      mController.Stop();
    }
  }
}