JobExecutionStatus.cs

using System;
using System.Threading;
using System.Threading.Tasks;
using Waher.Jobs.NodeTypes;
using Waher.Runtime.Language;
using Waher.Script;
using Waher.Things.Queries;
 
namespace Waher.Jobs
{
    public class JobExecutionStatus : IDisposable
    {
        private readonly DateTime startTime = DateTime.UtcNow;
        private readonly Variables variables = new Variables();
        private readonly Query query;
        private readonly Language language;
        private readonly JobReportDetail reportDetail;
        private readonly SemaphoreSlim semaphore = new SemaphoreSlim(1);
 
        public JobExecutionStatus(Job Job, Query Query, Language Language,
            JobReportDetail ReportDetail)
        {
            this.Job = Job;
            this.query = Query;
            this.language = Language;
            this.reportDetail = ReportDetail;
        }
 
        public Job Job { get; }
 
        public Query Query => this.query;
 
        public Language Language => this.language;
 
        public JobReportDetail ReportDetail => this.reportDetail;
 
        public DateTime StartTime => this.startTime;
 
        public Variables Variables => this.variables;
 
        public void Dispose()
        {
            this.semaphore.Dispose();
        }
 
        public async Task Lock()
        {
            await this.semaphore.WaitAsync();
        }
 
        public void Unlock()
        {
            this.semaphore.Release();
        }
    }
}