using Aitex.Core.Util;
using MECF.Framework.Common.Jobs;
using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace CyberX8_RT.Dispatch
{
    public class FaJobManager : Singleton<FaJobManager>
    {
        #region 内部变量
        /// <summary>
        /// ControlJob
        /// </summary>
        private ConcurrentBag<string> _faControlJobs = new ConcurrentBag<string>();       
        #endregion
        /// <summary>
        /// 增加
        /// </summary>
        /// <param name="jobName"></param>
        /// <returns></returns>
        public bool Add(string jobName)
        {
            if (_faControlJobs.Contains(jobName))
            {
                return false;
            }
            _faControlJobs.Add(jobName); 
            return true;
        }
        /// <summary>
        /// 是否包含
        /// </summary>
        /// <param name="jobName"></param>
        /// <returns></returns>
        public bool Contains(string jobName)
        {
            return _faControlJobs.Contains(jobName);
        }
        /// <summary>
        /// 任务完成
        /// </summary>
        /// <param name="jobName"></param>
        public void Complete(string jobName)
        {
            if(_faControlJobs.Contains(jobName))
            {
                _faControlJobs.TryTake(out jobName);
            }
        }
    }
}