sending db object to new thread's class

Question

i want to send db object to my new thread's constructor method how can i do

db = DBContext.CreateInstance(ConfigurationManager.ConnectionStrings["EDocSis.DAL.EDefterDB"].ConnectionString);
    FaturaUploadTreadHelper helper = new FaturaUploadTreadHelper(kurumVeriAktarimList);
                        ThreadStart job = new ThreadStart(helper.UpdateRecords);
                        Thread thread = new Thread(job);
                        thread.Start();


/////////////////////////////////////////////////////////////////
 public string ManuelFaturaUploadDirectory
        {
            get { return ConfigurationManager.AppSettings.Get("ManuelFaturaUploadDirectory"); }
        }
        public IEDefterDB db { get; set; }
        public string RealFileName { get; set; }
        public string KurumVkn { get; set; }
        public string FileExtension { get; set; }
        public int RowCount { get; set; }
        public long ContentLength { get; set; }
        public int KurumID { get; set; }
        public int VeriAktarimID { get; set; }
        public List<EDocSis.DAL.EFatura.KurumVeriAktarim> KurumVeriAktarimlariList { get; set; }

        public FaturaUploadTreadHelper(List<EDocSis.DAL.EFatura.KurumVeriAktarim> kurumVeriAktarimlariList = null)
        {

            this.KurumVeriAktarimlariList = kurumVeriAktarimlariList;
        }

        public void UpdateRecords()
        {
            foreach (var kurumVeriAktarim in this.KurumVeriAktarimlariList)
            {
                this.VeriAktarimID = kurumVeriAktarim.ID;
                var tempFileName = Path.GetFileName(kurumVeriAktarim.DosyaBilgisi);
                this.RealFileName = tempFileName;
                var vkn = db.KurumDetaylari.First(x => x.ID == kurumVeriAktarim.Parent.ID).KimlikNo;
                this.KurumVkn = vkn;
                var extension = Path.GetExtension(kurumVeriAktarim.DosyaBilgisi);
                this.FileExtension = extension;
                this.RowCount = kurumVeriAktarim.SatirSayisi;
                this.ContentLength = kurumVeriAktarim.ToplamBuyukluk;
                this.KurumID = kurumVeriAktarim.Parent.ID;
                Run();
            }

Each thread should have their own DB instance. Why don't you passes the connection string, instead? — EProgrammerNotFound
– EProgrammerNotFound, Commented Dec 3, 2013 at 14:20
so i should create db object in constructor method for each thread is it true ? — altandogan
– altandogan, Commented Dec 3, 2013 at 14:21
As @Michael said, we can't dictate anything since we don't know if DBContext is thread safe. Usually, they don't, but who knows? — EProgrammerNotFound
– EProgrammerNotFound, Commented Dec 3, 2013 at 14:25

Mike Perrenoud · Accepted Answer · 2013-12-03 14:44:17Z

3

The Thread.Start method has an overload that receives an object. Modify your method UpdateRecords to receive an object:

UpdateRecords(object db)

then change this line ThreadStart job = new ThreadStart(helper.UpdateRecords); to this:

ParameterizedThreadStart job =
    new ParameterizedThreadStart(helper.UpdateRecords);

and then when you start the thread:

thread.Start(db);

As stated by Matheus, it's likely that each thread should have its own db instance, but I can't really dictate that. I don't know near enough (and honestly couldn't) about your application.

edited Dec 3, 2013 at 14:44

answered Dec 3, 2013 at 14:21

Mike Perrenoud

68.1k32 gold badges167 silver badges238 bronze badges

Sign up to request clarification or add additional context in comments.

4 Comments

altandogan Over a year ago

i don't TreadStart methods want to any void method when i give a parameter objec db it don't accept it understand ThreadStart job = new ThreadStart(helper.UpdateRecords); Thread thread = new Thread(job); thread.Start(db);

Mike Perrenoud Over a year ago

@user990513, I'm not understanding what you're saying. The method that you're starting on a new thread, UpdateRecords, can be modified to receive the db object. It just needs to have a parameter typed as an object. You'd clearly have to cast it inside of there. Then, when you issue Thread.Start, just pass that object into it.

EProgrammerNotFound Over a year ago

@user990513 OP needs to change ThreadStart to ParametrizedThreadStart

Mike Perrenoud Over a year ago

@MatheusFreitas, fantastic addition my friend! Just fantastic. I'll update the answer.

Bura Chuhadar · Accepted Answer · 2013-12-03 22:25:00Z

2

You can do it like that:

db = DBContext.CreateInstance(ConfigurationManager.ConnectionStrings["EDocSis.DAL.EDefterDB"].ConnectionString);
    FaturaUploadTreadHelper helper = new FaturaUploadTreadHelper(kurumVeriAktarimList);

                        Thread thread = new Thread(
                            unused => UpdateRecords(db)
                        );
                        thread.Start();

        public void UpdateRecords(object db)
        {
//DBContext for thread safe purposes.
 db = DBContext.CreateInstance(ConfigurationManager.ConnectionStrings["EDocSis.DAL.EDefterDB"].ConnectionString);

            foreach (var kurumVeriAktarim in this.KurumVeriAktarimlariList)
            {
                this.VeriAktarimID = kurumVeriAktarim.ID;
                var tempFileName = Path.GetFileName(kurumVeriAktarim.DosyaBilgisi);
                this.RealFileName = tempFileName;
                var vkn = db.KurumDetaylari.First(x => x.ID == kurumVeriAktarim.Parent.ID).KimlikNo;
                this.KurumVkn = vkn;
                var extension = Path.GetExtension(kurumVeriAktarim.DosyaBilgisi);
                this.FileExtension = extension;
                this.RowCount = kurumVeriAktarim.SatirSayisi;
                this.ContentLength = kurumVeriAktarim.ToplamBuyukluk;
                this.KurumID = kurumVeriAktarim.Parent.ID;
                Run();
            }

One thing you must know that, DBContext is not thread safe, even you send your object as a parameter, you have to create a new connection. But also it doesn't make sense to send your dbContext as a parameter for your method.

edited Dec 3, 2013 at 22:25

answered Dec 3, 2013 at 14:44

Bura Chuhadar

3,7711 gold badge16 silver badges17 bronze badges

4 Comments

altandogan Over a year ago

i am doing this but i receive that error :The ObjectContext instance has been disposed and can no longer be used for operations that require a connection. var vkn = db.KurumDetaylari.First(x => x.ID == kurumVeriAktarim.Parent.ID).KimlikNo;

Bura Chuhadar Over a year ago

One thing you must know that, DBContext is not thread safe, even you send your object a parameter, you have create a new connection. But also it doesn't make sense to send your dbContext as a parameter for your method.

altandogan Over a year ago

sending dbContext is a bad approach ? is it True? if is it true i will create a db connection in my thread method

Bura Chuhadar Over a year ago

if you are using threads then yes it is a bad approach to send the dbContext as a parameter.

Collectives™ on Stack Overflow

sending db object to new thread's class

2 Answers 2

4 Comments

4 Comments

Your Answer

Linked

Hot Network Questions

Collectives™ on Stack Overflow

2 Answers 2

4 Comments

4 Comments

Your Answer

Sign up or log in

Post as a guest

Linked

Related