如何异步调用方法
本文关键字:调用 方法 异步 何异步 | 更新日期: 2023-09-27 18:31:01
我试过点击这个链接异步调用,但有些类已经过时了。
所以我想要我的项目一个确切的答案。
public class RegisterInfo
{
public bool Register(UserInfo info)
{
try
{
using (mydatabase db = new mydatabase())
{
userinfotable uinfo = new userinfotable();
uinfo.Name = info.Name;
uinfo.Age = info.Age;
uinfo.Address = info.Address;
db.userinfotables.AddObject(uinfo);
db.SaveChanges();
// Should be called asynchronously
Utility.SendEmail(info); // this tooks 5 to 10 seconds or more.
return true;
}
}
catch { return false; }
}
}
public class UserInfo
{
public UserInfo() { }
public string Name { get; set; }
public int Age { get; set; }
public string Address { get; set; }
}
public class Utility
{
public static bool SendEmail(UserInfo info)
{
MailMessage compose = SomeClassThatComposeMessage(info);
return SendEmail(compose);
}
private static bool SendEmail(MailMessage mail)
{
try
{
SmtpClient client = new SmtpClient();
client.Host = "smtp.something.com";
client.Port = 123;
client.Credentials = new System.Net.NetworkCredential("username@domainserver.com", "password");
client.EnableSsl = true;
ServicePointManager.ServerCertificateValidationCallback = new RemoteCertificateValidationCallback(ValidateServerCertificate);
client.Send(mail);
return true;
}
catch { return false; }
}
}
请查看Register
方法。保存数据后,我不想等待邮件发送。如果可能的话,我想处理其他线程上的邮件发送,这样用户就不会等待更长的时间。
我不需要知道邮件是否已成功发送。
希望你能理解我的意思。对不起,我的英语不好。
使用 Thread
:
new Thread(() => Utility.SendEmail(info)).Start();
使用ThreadPool
:
ThreadPool.QueueUserWorkItem(s => Utility.SendEmail(info));
使用Task
:
Task.Factory.StartNew(() => Utility.SendEmail(info));
当然,Thread
和ThreadPool
需要using System.Threading
,而Task
需要using System.Threading.Tasks
正如David Anderson所说,SmtpClient已经支持异步发送(我可能应该关注函数的内容而不是回答问题),所以从技术上讲,你可以用它来处理发送,尽管它不会卸载整个方法的处理。
SmtpClient 已经有一个 SendAsync 方法。您无需编写自己的异步代码即可执行此操作。
@Comment关于 SmtpClient 无法开箱即用 ASP.NET:
这绝对不是真的,它工作得很好,是推荐的API。但是,您必须了解 ASP.NET 页面生命周期以及线程在服务器上的行为方式。否则没有理由不使用它。
或者使用异步 CTP。
public async Task<bool> Register(UserInfo info)
{
try
{
using (mydatabase db = new mydatabase())
{
userinfotable uinfo = new userinfotable();
uinfo.Name = info.Name;
uinfo.Age = info.Age;
uinfo.Address = info.Address;
db.userinfotables.AddObject(uinfo);
db.SaveChanges();
//Wait for task to finish asynchronously
await Utility.SendEmail(info);
return true;
}
}
catch { return false; }
}
private Task SendEmail(MailMessage mail)
{
SmtpClient client = new SmtpClient();
client.Host = "smtp.something.com";
client.Port = 123;
client.Credentials = new System.Net.NetworkCredential("username@domainserver.com", "password");
client.EnableSsl = true;
ServicePointManager.ServerCertificateValidationCallback = new RemoteCertificateValidationCallback(ValidateServerCertificate);
//The smtp SendTaskAsync is an extension method when using Async CTP
return client.SendTaskAsync("from", "recipients", "subject", "body");
}
原始代码中也存在错误。当在 SendEmail 函数中引发异常时,它返回 false,但在寄存器函数中它仍将返回 true。假设布尔值表示成功或失败。