发布：2022/12/26 15:22:27作者：管理员 来源：本站 浏览次数：500

下面一段内容有项目需求有项目分析，通过一个小demo给大家展示下C#如何对多线程、多任务管理的。

项目需求：假设多个任务需要执行，每个任务不是一时半会能完成（需要能看到中间执行状况）；

        多个任务 根据条件不同 可能需要不同的处理

项目分析： 多线程并发执行多任务；

        对任务进行管理，追踪中间执行状态；

        运用策略模式抽象执行类；

public enum TaskStatus

  {

    wait = 0,

    working = 1,

    stop = 2,

    suspend = 3,

    complete = 4,

    fail = 5,

    other = 99

  }

 public class Task

   {

     public TaskDelegate<ParaStatus> taskStatus;

     public TaskDelegate<ParaInfo> taskInfo;

     public TaskDelegate<ParaProcess> taskProcess;

     private TaskStatus _status = TaskStatus.wait;

     private IExecuter _Executer { get; set; }

     private Guid _taskId;

     private Thread thread;

     private string _name;

     public Task(Guid id, IExecuter Executer)

     {

       _taskId = id;

       _Executer = Executer;

       _Executer.TaskId = id;

       _Executer.Task = this;

     }

     public void Wait()

     {

       ChangeStatus(TaskStatus.wait);

     }

     public string Name

     {

       get

       {

         return _name;

       }

       set

       {

         _name = value;

       }

     }

     public Guid TaskId

     {

       get

       {

         return _taskId;

       }

     }

     public TaskStatus Status

     {

       get

       {

         return _status;

       }

       set

       {

         _status = value;

       }

     }    

     public void Start()

     {

       if (thread == null)

       {

         thread = new Thread(_Executer.Do);

       }

       else if (thread.ThreadState == ThreadState.Stopped)

       {

         thread = new Thread(_Executer.Do);

       }

       thread.Start();

       ChangeStatus(TaskStatus.working);

     }

     public void ChangeStatus(TaskStatus s)

     {

       Status = s;

       ParaStatus ps = new ParaStatus(TaskId);

       ps.Status = Status;

       if (taskStatus != null) taskStatus(ps);

     }

     public void Stop()

     {

       if (thread != null)

       {

         if (thread.IsAlive)

         {

           try

           {

             thread.Abort();

           }

           catch { }

         }

       }

       ChangeStatus(TaskStatus.stop);

     }

     public void Suspend()

     {

       try

       {

         thread.Suspend();

       }

       catch { }

       ChangeStatus(TaskStatus.suspend);

     }

     public void Resume()

     {

       if (thread.IsAlive)

       {

         thread.Resume();

       }

       ChangeStatus(TaskStatus.working);

     }

   }

public interface IExecuter

  {

    Guid TaskId { get; set; }

    Task Task { get; set; }

    void Do();

  }

public class Executer : IExecuter

  {

    public void Execute()

    {

    }

    #region IExecute

    public Guid TaskId { get; set; }

    public Task Task { get; set; }

    public void Do()

    {

      for (int i = 1; i <= 100; i++)

      {

        if (Task.taskProcess != null)

        {

          Thread.Sleep(1000);

          ParaProcess pp = new ParaProcess(TaskId);

          pp.Rate = (double)i / 100;

          Task.taskProcess(pp);

        }

      }

      if (Task.taskStatus != null)

      {

        Task.ChangeStatus(TaskStatus.complete);

      }

    }

    #endregion

  }

public class TaskManager

  {

    public List<Task> Tasks = new List<Task>();

    /// <summary>

    /// 添加任务

    /// </summary>

    public Task AddTask(Task task)

    {

      try

      {

        Tasks.Add(task);

        task.Wait();

      }

      catch (Exception e)

      {

      }

      return task;

    }

    public void StartTask(Task task)

    {

      task.Start();

    }

    /// <summary>

    /// 停止任务

    /// </summary>

    /// <param name="downloader"></param>

    public void StopTask(Task task)

    {

      task.Stop();

    }

    public void SuspendTask(Task task)

    {

      task.Suspend();

    }

    public void ResumeTask(Task task)

    {

      task.Resume();

    }

    /// <summary>

    /// 删除任务(自动终止未停止的任务)

    /// </summary>

    /// <param name="downloader"></param>

    public void DeleteTask(Task task, bool deleteFile)

    {

      //先停止任务

      task.Stop();

      while (task.Status == TaskStatus.working)

      {

        Thread.Sleep(50);

      }

      //从任务列表中删除任务

      if (Tasks.Contains(task))

      {

        Tasks.Remove(task);

      }

    }

  }

 /// </summary>

  /// <param name="para">泛型参数</param>

  public delegate void TaskDelegate<T>(T para);

  /// <summary>

  ///

  /// </summary>

  public class ParaStatus

  {

    public ParaStatus(Guid task) { TaskId = task; }

    public Guid TaskId { get; set; }

    public TaskStatus Status { get; set; }

  }  

  public class ParaInfo

  {

    public ParaInfo(Guid task) { TaskId = task; }

    public Guid TaskId { get; set; }

    public string Info { get; set; }

  }

  public class ParaProcess

  {

    public ParaProcess(Guid task) { TaskId = task; }

    public Guid TaskId { get; set; }

    public double Rate { get; set; }    

  }

以上代码内容就是C#对多线程、多任务管理的方法，希望对大家有所帮助。