// COPYRIGHT (C) Tom. ALL RIGHTS RESERVED. // THE AntdUI PROJECT IS AN WINFORM LIBRARY LICENSED UNDER THE Apache-2.0 License. // LICENSED UNDER THE Apache License, VERSION 2.0 (THE "License") // YOU MAY NOT USE THIS FILE EXCEPT IN COMPLIANCE WITH THE License. // YOU MAY OBTAIN A COPY OF THE LICENSE AT // // http://www.apache.org/licenses/LICENSE-2.0 // // UNLESS REQUIRED BY APPLICABLE LAW OR AGREED TO IN WRITING, SOFTWARE // DISTRIBUTED UNDER THE LICENSE IS DISTRIBUTED ON AN "AS IS" BASIS, // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, EITHER EXPRESS OR IMPLIED. // SEE THE LICENSE FOR THE SPECIFIC LANGUAGE GOVERNING PERMISSIONS AND // LIMITATIONS UNDER THE License. // GITEE: https://gitee.com/antdui/AntdUI // GITHUB: https://github.com/AntdUI/AntdUI // CSDN: https://blog.csdn.net/v_132 // QQ: 17379620 using System; using System.Threading; using System.Threading.Tasks; using System.Windows.Forms; namespace AntdUI { public class ITask : IDisposable { public bool IsRun = false; /// /// 循环任务 /// /// 回调 /// 间隔 /// 最大值 /// 更新量 public ITask(Control control, Func action, int interval, int max, int add, Action? end = null) { bool ok = true; IsRun = true; task = Run(() => { int val = 0; while (true) { if (token.Wait(control)) { ok = false; return; } else { val += add; if (val > max) val = 0; if (action(val)) Thread.Sleep(interval); else return; } } }).ContinueWith((action => { Dispose(); if (ok && end != null) end(); })); } public ITask(Control control, Action action, int interval, float max, float add, Action? end = null) { bool ok = true; IsRun = true; task = Run(() => { float val = 0; while (true) { if (token.Wait(control)) { ok = false; return; } else { val += add; if (val > max) val = 0; action(val); Thread.Sleep(interval); } } }).ContinueWith((action => { Dispose(); if (ok && end != null) end(); })); } public ITask(Control control, Func action, int interval, Action? end = null) { bool ok = true; IsRun = true; task = Run(() => { while (true) { if (token.Wait(control)) { ok = false; return; } else { if (action()) Thread.Sleep(interval); else return; } } }).ContinueWith((action => { Dispose(); if (ok && end != null) end(); })); } public ITask(Func action, int interval, int totalFrames, Action end, int sleep = 0) { IsRun = true; bool ok = true; task = Run(() => { if (sleep > 0) Thread.Sleep(sleep); for (int i = 0; i < totalFrames; i++) { if (token.Wait()) { ok = false; return; } else { if (action(i + 1)) Thread.Sleep(interval); else return; } } }).ContinueWith((action => { Dispose(); if (ok) end(); })); } public ITask(bool _is, int interval, int totalFrames, float cold, AnimationType type, Action action, Action end) { IsRun = true; bool ok = true; task = Run(() => { double init_val = 1D; if (_is) { if (cold > -1) init_val = cold; for (int i = 0; i < totalFrames; i++) { if (token.Wait()) { ok = false; return; } else { int currentFrames = i + 1; double progress = ((currentFrames * 1.0) / totalFrames); var prog = (float)(init_val - Animation.Animate(progress, init_val, type)); Tag = prog; action(currentFrames, prog); Thread.Sleep(interval); } } } else { if (cold > -1) init_val = cold; else init_val = 0; for (int i = 0; i < totalFrames; i++) { if (token.Wait()) { ok = false; return; } else { int currentFrames = i + 1; double progress = ((currentFrames * 1.0) / totalFrames); var prog = (float)(Animation.Animate(progress, 1D + init_val, type) - init_val); if (prog < 0) return; Tag = prog; action(currentFrames, prog); Thread.Sleep(interval); } } } }).ContinueWith((action => { Dispose(); if (ok) { Tag = null; end(); } })); } Task task; public void Wait() => task.Wait(); public object? Tag { get; set; } = null; public void Cancel() { token?.Cancel(); } public void Dispose() { if (token != null) { token?.Cancel(); token?.Dispose(); token = null; } IsRun = false; } CancellationTokenSource? token = new CancellationTokenSource(); public static Task Run(Action action, Action? end = null) { if (end == null) { #if NET40 return Task.Factory.StartNew(action); #else return Task.Run(action); #endif } #if NET40 return Task.Factory.StartNew(action).ContinueWith(action => { end(); }); #else return Task.Run(action).ContinueWith(action => { end(); }); #endif } } }