概念

  • 函数防抖(debounce):当频繁持续触发事件时,如果在设定时间间隔内重复触发事件,每次触发时间就重新开始计时,直至指定时间间隔内没有再触发事件,事件处理函数才会执行一次
  • 函数节流(throttle):当频繁持续触发事件时,保证每隔指定时间调用一次事件处理函数,指定间隔内只会调用一次

  • debounce限制多长时间才能执行一次,

  • throttle限制多长时间必须执行一次,
  • 一个限制上限、一个限制下限

函数防抖

  1. using System;
  2. using System.ComponentModel;
  3. using System.Threading;
  4. namespace Common
  5. {
  6. /// <summary>
  7. /// 防抖活动--多次重复调用时,间隔固定时长不调用时执行一次
  8. /// </summary>
  9. public class DebounceAction
  10. {
  11. private Timer _timer;
  12. private ISynchronizeInvoke _invoker;
  13. private Action _action;
  14. public TimeSpan Delay { get; private set; }
  15. public DebounceAction(TimeSpan delay)
  16. {
  17. Delay = delay;
  18. }
  19. public DebounceAction(Action action, TimeSpan delay) : this(delay)
  20. {
  21. _action = action;
  22. }
  23. /// <summary>
  24. /// 间隔固定时长不调用时执行一次
  25. /// </summary>
  26. public void Execute(ISynchronizeInvoke invoker = null)
  27. {
  28. Monitor.Enter(this);
  29. bool needExit = true;
  30. try
  31. {
  32. _invoker = invoker;
  33. Cancel();
  34. _timer = new Timer(OnTimeTicked, null, (int)Delay.TotalMilliseconds, Timeout.Infinite);
  35. Monitor.Exit(this);
  36. needExit = false;
  37. }
  38. finally
  39. {
  40. if (needExit)
  41. Monitor.Exit(this);
  42. }
  43. }
  44. /// <summary>
  45. /// 取消防抖操作
  46. /// </summary>
  47. public void Cancel()
  48. {
  49. if (_timer != null)
  50. {
  51. _timer.Dispose();
  52. _timer = null;
  53. }
  54. }
  55. private void OnTimeTicked(object state)
  56. {
  57. Cancel();
  58. if (_action != null)
  59. {
  60. if (_invoker != null && _invoker.InvokeRequired)
  61. {
  62. _invoker.Invoke(_action, null);
  63. }
  64. else
  65. {
  66. _action.Invoke();
  67. }
  68. }
  69. }
  70. }
  71. }

函数节流

  1. using System;
  2. using System.ComponentModel;
  3. using System.Threading;
  4. namespace Common
  5. {
  6. /// <summary>
  7. /// 节流活动--多次重复调用时,每间隔固定时长执行一次
  8. /// </summary>
  9. public class ThrottleAction
  10. {
  11. private Timer _timer;
  12. private Action _action;
  13. private ISynchronizeInvoke _invoker;
  14. public TimeSpan Delay { get; private set; }
  15. public ThrottleAction(TimeSpan delay)
  16. {
  17. Delay = delay;
  18. }
  19. public ThrottleAction(Action action, TimeSpan delay)
  20. : this(delay)
  21. {
  22. _action = action;
  23. }
  24. /// <summary>
  25. /// 每间隔固定时长执行一次
  26. /// </summary>
  27. /// <param name="invoker"></param>
  28. public void Execute(ISynchronizeInvoke invoker = null)
  29. {
  30. Monitor.Enter(this);
  31. bool needExit = true;
  32. try
  33. {
  34. _invoker = invoker;
  35. if (_timer == null)
  36. {
  37. _timer = new Timer(OnTimeTicked, null, (int)Delay.TotalMilliseconds, Timeout.Infinite);
  38. Monitor.Exit(this);
  39. needExit = false;
  40. }
  41. }
  42. finally
  43. {
  44. if (needExit)
  45. Monitor.Exit(this);
  46. }
  47. }
  48. /// <summary>
  49. /// 取消节流操作
  50. /// </summary>
  51. public void Cancel()
  52. {
  53. if (_timer != null)
  54. {
  55. _timer.Dispose();
  56. _timer = null;
  57. }
  58. }
  59. private void OnTimeTicked(object state)
  60. {
  61. Cancel();
  62. if (_action != null)
  63. {
  64. if (_invoker != null && _invoker.InvokeRequired)
  65. {
  66. _invoker.Invoke(_action, null);
  67. }
  68. else
  69. {
  70. _action.Invoke();
  71. }
  72. }
  73. }
  74. }
  75. }

参考资料