• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

ASP.NET 页面异步任务

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

PageAsyncTask是任务类,通过 Page.RegisterAsyncTask来注册,Page.ExecuteRegisteredAsyncTasks()调用

页面代码:

<%@ Page Language="C#" AutoEventWireup="true" CodeFile="Default.aspx.cs" Inherits="_Default" AsyncTimeout="4" %>

<html xmlns="http://www.w3.org/1999/xhtml" >
<head id="Head1" runat="server">
    <title>Asynchronous Task Example</title>
</head>
<body>
    <form id="form1" runat="server">
    <div>
      <span id="TaskMessage" runat=server>
      </span>
    </div>
    </form>
</body>
</html>

后置代码:

using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Web.UI;
using System.Web.UI.WebControls;
using System.Threading;

public partial class _Default : System.Web.UI.Page
{
    protected void Page_Load(object sender, EventArgs e)
    {
        // 定义异步任务.
        SlowTask slowTask1 = new SlowTask();
        SlowTask slowTask2 =new SlowTask();
        SlowTask slowTask3 =new SlowTask();

        PageAsyncTask asyncTask1 = new PageAsyncTask(slowTask1.OnBegin, slowTask1.OnEnd, slowTask1.OnTimeout, "Async1", true);
        PageAsyncTask asyncTask2 = new PageAsyncTask(slowTask2.OnBegin, slowTask2.OnEnd, slowTask2.OnTimeout, "Async2", true);
        PageAsyncTask asyncTask3 = new PageAsyncTask(slowTask3.OnBegin, slowTask3.OnEnd, slowTask3.OnTimeout, "Async3", true);

        //注册页面异步任务.
        //单个任务如果超过页面定义的AsyncTimeout,就会调用Timeout委托
        Page.RegisterAsyncTask(asyncTask1);
        Page.RegisterAsyncTask(asyncTask2);
        Page.RegisterAsyncTask(asyncTask3);

        DateTime tStart = DateTime.Now;
        // 执行注册的异步方法,会阻塞线程,直到所有注册方法执行完毕或者超时
        Page.ExecuteRegisteredAsyncTasks();
        DateTime tEnd = DateTime.Now;

        TaskMessage.InnerHtml =
            "Task1:"+slowTask1.GetAsyncTaskProgress() + "<br>" +
            "Task2:"+slowTask2.GetAsyncTaskProgress() + "<br>" +
            "Task3:"+slowTask3.GetAsyncTaskProgress() + "<br/>"+
             "总开始时间:" + tStart + "  总结束时间:" + tEnd;
    }

    public class SlowTask
    {
        private static Random rand = new Random();
        private String _taskprogress;
        private AsyncTaskDelegate _dlgt;

        // Create delegate.
        protected delegate void AsyncTaskDelegate();

        public String GetAsyncTaskProgress()
        {
            return _taskprogress;
        }

        //实际执行的耗时操作
        public void ExecuteAsyncTask()
        {
            //随即生产1-5秒模拟调用耗时
            int second = rand.Next(1, 5);
            Thread.Sleep(TimeSpan.FromSeconds(second));
        }

        //异步调用开始时调用
        //此方法内一般不放耗时操作,而是内部新建线程执行
        public IAsyncResult OnBegin(object sender, EventArgs e,
            AsyncCallback cb, object extraData)
        {
            _taskprogress = "开始时间: " + DateTime.Now + ". ";
            //这里定义耗时方法的委托,并开始异步执行
            //虽然直接将耗时操作直接写在OnBegin可以有相同的效果,但是使用单独委托可以更灵活
            //比如可以通过委托传递由外部定义的耗时操作
            _dlgt = new AsyncTaskDelegate(ExecuteAsyncTask);
            IAsyncResult result = _dlgt.BeginInvoke(cb, extraData);

            return result;
        }

        // 异步调用结束时被调用
        public void OnEnd(IAsyncResult ar)
        {
            _taskprogress += "完成时间: " + DateTime.Now;
            _dlgt.EndInvoke(ar);
        }

        //异步调用在指定时间未完成时被调用(即超时)
        public void OnTimeout(IAsyncResult ar)
        {
            _taskprogress += "异步操作超时";
        }
    }
}

用处:
使用异步任务可以最大限度利用多核服务器

还可以利用ExecuteRegisteredAsyncTasks的阻塞功能实现简单Server-Push效果

思路:

  服务端: 可以将异步方法放入某个类实例,方法中使用ManualResetEvent或其他同步类,阻塞方法执行,将类实例放入全局变量中,如Dictionary,当满足某些条件时(如某个请求),在全局变量中找出对应类,通过类的公开方法释放ManualResetEvent锁定返回是数据

 客户端:根据服务端返回的信息作出不同反应,不管是超时还是正常得到数据,都再向服务器开ajax请求,等待服务器新的响应


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
(转)asp.net中使用ajax中的三种方式发布时间:2022-07-10
下一篇:
配置ASP.NETLinux(CentOS6.5)运行环境MONO+Jexus发布时间:2022-07-10
热门推荐
热门话题
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap