Timeout exception in threading

Question

I have implemented threading to call 5 methods to send different email notifications through windows services. It is throwing timeout exception every time. Please suggest me if is there any way to fix this issue.

Imran Ahmed · Answer

The following is my implementation. Parallel.Invoke( new Action(GetSelectedUserDetailsNotification) new Action(GetAdminNotification) new Action(GetAdminNotification4CompanyTrail) new Action(TrialPeriodEndedAndNotConverted) new Action(CustomerBankAccountRegistrationReminder) ); public void GetSelectedUserDetailsNotification() { serviceStatusUserDetails = objBLL.GetUserDetailsNotification(); Thread.Sleep(60000); } public void GetAdminNotification() { serviceStatusCompanyStatusFunctionality = objBLL.CompanyStatusFunctionality(); Thread.Sleep(30000); } void GetAdminNotification4CompanyTrail() { serviceStatusTrail = objBLL.CompanyTrailPeriodFunctionality(); Thread.Sleep(30000); } public void TrialPeriodEndedAndNotConverted() { serviceStatusTrialExpired = objBLL.TrialPeriodEndedAndNotConverted(); Thread.Sleep(30000); } public void CustomerBankAccountRegistrationReminder() { serviceStatusCustomerBAR = objBLL.CustomerBankAccountRegistrationReminder(); Thread.Sleep(30000); }

Imran Ahmed · Answer

The following is my exception. Please find. Error Message : Timeout expired. The timeout period elapsed prior to completion of the operation or the server is not responding. Error Trace Object : at System.Data.SqlClient.SqlConnection.OnError(SqlException exception Boolean breakConnection Action`1 wrapCloseInAction) at System.Data.SqlClient.TdsParser.ThrowExceptionAndWarning(TdsParserStateObject stateObj Boolean callerHasConnectionLock Boolean asyncClose) at System.Data.SqlClient.TdsParser.TryRun(RunBehavior runBehavior SqlCommand cmdHandler SqlDataReader dataStream BulkCopySimpleResultSet bulkCopyHandler TdsParserStateObject stateObj Boolean& dataReady) at System.Data.SqlClient.SqlDataReader.TryConsumeMetaData() at System.Data.SqlClient.SqlDataReader.get_MetaData() at System.Data.SqlClient.SqlCommand.FinishExecuteReader(SqlDataReader ds RunBehavior runBehavior String resetOptionsString) at System.Data.SqlClient.SqlCommand.RunExecuteReaderTds(CommandBehavior cmdBehavior RunBehavior runBehavior Boolean returnStream Boolean async Int32 timeout Task& task Boolean asyncWrite SqlDataReader ds) at System.Data.SqlClient.SqlCommand.RunExecuteReader(CommandBehavior cmdBehavior RunBehavior runBehavior Boolean returnStream String method TaskCompletionSource`1 completion Int32 timeout Task& task Boolean asyncWrite) at System.Data.SqlClient.SqlCommand.RunExecuteReader(CommandBehavior cmdBehavior RunBehavior runBehavior Boolean returnStream String method) at System.Data.SqlClient.SqlCommand.ExecuteReader(CommandBehavior behavior String method) at System.Data.SqlClient.SqlCommand.ExecuteDbDataReader(CommandBehavior behavior) at System.Data.Common.DbCommand.System.Data.IDbCommand.ExecuteReader(CommandBehavior behavior) at System.Data.Common.DbDataAdapter.FillInternal(DataSet dataset DataTable[] datatables Int32 startRecord Int32 maxRecords String srcTable IDbCommand command CommandBehavior behavior) at System.Data.Common.DbDataAdapter.Fill(DataSet dataSet Int32 startRecord Int32 maxRecords String srcTable IDbCommand command CommandBehavior behavior) at System.Data.Common.DbDataAdapter.Fill(DataSet dataSet) at Microsoft.Practices.EnterpriseLibrary.Data.Database.DoLoadDataSet(IDbCommand command DataSet dataSet String[] tableNames) at Microsoft.Practices.EnterpriseLibrary.Data.Database.LoadDataSet(DbCommand command DataSet dataSet String[] tableNames) at Microsoft.Practices.EnterpriseLibrary.Data.Database.ExecuteDataSet(DbCommand command) at EmailNotification.SendEmailDAL.GetDocumentDetails(Int32 companyid String status Boolean all Boolean todayonly Boolean recurringcreate Boolean recurringmodified Boolean scheduledpayment Boolean voidcheck Boolean moneywithdrawfrombank Int32 readyforreview_value Int32 readyforapproval_value Int32 scheduled_value Int32 deposited_value Int32 voidcheckpending_value Int32 cancelled_value Int32 markasPaid_value String dbtranconstring Int32 UserId String Scheduledtodaydate Nullable`1 ScheduleConfigDay) in d:\TFS\XTBills\XTBills\Deployment\R24.1\XTBills.Services\EmailNotification\SendEmailDAL.cs:line 167 at EmailNotification.SendEmailBLL.GetDocumentDetails(Int32 companyid String status Boolean all Boolean todayonly Boolean recurringcreate Boolean recurringmodified Boolean scheduledpayment Boolean voidcheck Boolean moneywithdrawfrombank Int32 readyforreview_value Int32 readyforapproval_value Int32 scheduled_value Int32 deposited_value Int32 voidcheckpending_value Int32 cancelled_value Int32 markasPaid_value String dbtranconstring Int32 UserId) in d:\TFS\XTBills\XTBills\Deployment\R24.1\XTBills.Services\EmailNotification\SendEmailBLL.cs:line 142 at EmailNotification.EmailNotification.GetUserDetails(Int32 readyforReview Int32 readyforApproval Int32 readyforPayment Int32 PartialyPaid Int32 recurringbillcreated Int32 recurringbillmodify Int32 scheduled Int32 voidcheckpending Int32 cancelled Int32 deposited Int32 companyid String dbtranconstring) in d:\TFS\XTBills\XTBills\Deployment\R24.1\XTBills.Services\EmailNotification\EmailNotification.cs:line 413 Error Time : 11-Apr-2018 04:03:01 AM

Mohan Arumugam · Answer

You could run the operation in a separate thread and then put a timeout on the thread join operation class Program { static void DoSomething () { try { // your call here... obj . PerformInitTransaction (); } catch ( ThreadAbortException ) { // cleanup code if needed... } } public static void Main ( params string [] args ) { Thread t = new Thread ( DoSomething ); t . Start (); if (! t . Join ( TimeSpan . FromSeconds ( 30 ))) { t . Abort (); throw new Exception ( More than 30 secs. ); } } }