c# taskscheduler使用场合_hbase shell put

c# taskscheduler使用场合_hbase shell put这里记录下TaskScheduler的简单用法。使用场景:在使用Task的时候,大家都知道用TaskFactory.StartNew可以用来创建一个Task。这里如果创建10个,那么这10个Task就各自放飞直接运行了。一般情况下是没什么大问题,如果这10个中的每个Task非常耗CPU或者内存,而公司的产品又是非常考验配置成本(比如一体机,移动设备等),就需要让这10个Task按照一定要求执行,比如串行执行,从而节省资源、让机器还可以顺畅去干别的事情。Task…

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE稳定放心使用

这里记录下 TaskScheduler 的简单用法。

使用场景:

      使用 Task 的时候,大家知道用 TaskFactory.StartNew 可以用来创建一个 Task 。这里如果创建了 3 个,那么这3个 Task 就各自放飞直接运行了。

class Program
{
	private static TaskFactory _taskFactory;
	static void Main(string[] args)
	{
		_taskFactory = new TaskFactory();

		_taskFactory.StartNew(Func1);
		_taskFactory.StartNew(Func2);
		_taskFactory.StartNew(Func3);

		Console.ReadLine();
	}

	static void Func1()
	{
		Thread.Sleep(3000);
		Console.WriteLine("Func1");
	}
	static void Func2()
	{
		Thread.Sleep(2000);
		Console.WriteLine("Func2");
	}
	static void Func3()
	{
		Thread.Sleep(1000);
		Console.WriteLine("Func3");
	}
}

结果:

Func3

Func2

Func1

一般情况下没什么大问题,但如果这3个中的每个Task都非常耗CPU或者内存,而计算机又需要预留资源去干别的事情,这就要让3个Task不能同时执行。又或者确实要让某些Task先做,有些后做。这就需要我们自己能够决定Task执行顺序。

怎样达到这样的效果?

答案就是:TaskScheduler,它可以让已经创建好的 Task 去按照特殊的顺序来执行。

就拿上面的场景来举例:

为了节约系统资源,我要让这3个Task单独执行,有一个在执行,其它俩就不能执行。最简单的就是串行执行,这样只需要写一个类继承TaskScheduler:

public class MyTaskScheduler : TaskScheduler, IDisposable
{
	private static readonly object _mutex = new object();
	public readonly List<Task> _currentTasks = new List<Task>();
	private readonly ManualResetEvent[] _schedulerEvents = new ManualResetEvent[2];
	public override int MaximumConcurrencyLevel => 1;

	public MyTaskScheduler()
	{
		_schedulerEvents[0] = new ManualResetEvent(false);
		_schedulerEvents[1] = new ManualResetEvent(false);

		var executionThread = new Thread(ExecutionThread) { Name = "MyThread" };
		executionThread.SetApartmentState(ApartmentState.MTA);
		executionThread.IsBackground = true;
		executionThread.Priority = ThreadPriority.Normal;
		executionThread.Start(null);
	}

	public void Dispose()
	{
		_schedulerEvents[1].Set();
	}

	private void ExecutionThread(object args)
	{
		try
		{

			while (true)
			{
				if (!WaitIfEmpty())
				{
					break;
				}

				Task task;
				lock (_mutex)
				{
					task = _currentTasks[0];
				}

				try
				{
					TryExecuteTask(task);
				}
				catch (Exception)
				{
					throw;
				}
				finally
				{
					TryDequeue(task);
				}
			}
		}
		finally
		{
			//todo
		}
	}
	private bool WaitIfEmpty()
	{
		lock (_mutex)
		{
			if (_currentTasks.Count == 0)
			{
				//pause task
				_schedulerEvents[0].Reset();
			}
		}

		//wait any signal.
		int id = WaitHandle.WaitAny(_schedulerEvents);

		// id is item index of _schedulerEvents
		return id == 0;
	}

	protected override IEnumerable<Task>? GetScheduledTasks()
	{
		lock (_mutex)
		{
			return _currentTasks.ToArray();
		}
	}
	protected override void QueueTask(Task task)
	{
		lock (_mutex)
		{
			_currentTasks.Add(task);

			if (_currentTasks.Count > 0)
			{
				// Start task
				_schedulerEvents[0].Set();
			}
		}
	}
	protected sealed override bool TryDequeue(Task task)
	{
		lock (_mutex)
		{
			var res = _currentTasks.Remove(task);
			return res;
		}
	}
	protected override bool TryExecuteTaskInline(Task task, bool taskWasPreviouslyQueued)
	{
		return false;
	}
}

主函数中只要稍作修改:

static void Main(string[] args)
{
	var taskScheduler = new MyTaskScheduler();
	_taskFactory = new TaskFactory(taskScheduler);

	_taskFactory.StartNew(Func1);
	_taskFactory.StartNew(Func2);
	_taskFactory.StartNew(Func3);

	Console.ReadLine();
}

运行结果:

Func1

Func2

Func3

在MyTaskScheduler 中,我建了一个线程 executionThread,线程方法是一个while循环,一直在监听有没有新的Task过来,有多个Task过来,就按Task创建顺序执行,没有的话 while 就暂停在 waitany 处。

这样的场景,配合 ManualResetEvent 和Task的CancellationTokenSource 非常适合做 带有暂停和取消功能的任务列表。

 

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/183039.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • think in java interview-高级开发人员面试宝典(八)

    think in java interview-高级开发人员面试宝典(八)JavaIO流的复习。大家平时J2EE写多了,JAVA的IO操作可能都已经生疏了,面试时如果来上这么几道,是不是有点”其实这个问题很简单,可是我就是想不起来“的感觉啊?呵呵!JAVA的IO操作太多,我这边挑腾迅,盛大和百度的几道面试题,并整理出答案来供大家参考。InputFromConsole这个最简单不过了,如果你不复习的话,嘿嘿,还真答不出,来看:packageorg.sky.io;p

  • SQl中的左连接,右连接,内连接,全连接,自连接的理解。

    SQl中的左连接,右连接,内连接,全连接,自连接的理解。

  • QMovie的使用

    QMovie的使用QMovie是一个可以存放动态视频的类今天第一次使用,记录一下一般是配合QLabel使用的,可以用来存放GIF动态图 m_background=newQLabel(this);m_background->setGeometry(0,0,MENU_WINDOW_WIDTH,MENU_WINDOW_HEIGHT);QMovie*backgroundMovie=newQMovie(“:/images/menu/MenuBackground.gif”,QByteArra

  • xshell的安装和使用_Xshell是什么

    xshell的安装和使用_Xshell是什么安装参考该链接安装家庭免费版,现在刚开始用,还不知道这个版本能不能满足我们日常的需求,等到后面使用一段时间再来更新!连接linuxwindows下使用xshell连接linux错误:Couldnotconnectto‘172.18.0.1’(port22):Connectionfailed首先我们需要安装sshsudoapt-getinstallsshsudoapt-getinstallopenssh-server每个人出现这个问题的原因都不太一样,要去排查自己

  • 计算机设备问题代码43,设备管理器错误代码(代码43)的六种解决方法

    内容一、“由于此设备存在问题,Windows已将其停止(代码43)”),这是问题的原因原因分析:代码43错误是多个设备管理器错误代码之一。当设备管理器停止硬件设备时,会生成此错误,这可能是由硬件设备或设备驱动程序故障引起的。设备管理器错误代码(代码43)的详细信息可以在设备属性的“设备状态”区域中找到。引起问题的设备将在设备中用感叹号标记)设备管理器,如下图所示:有关如何解决此问题的信息,…

  • Java操作MongoDB

    Java操作MongoDB

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号