using System;

using System.Data;

using System.Data.SqlClient;

using System.Threading;

​

namespace DeadlockTest

{

    class Program

    {

        static string connectionString = "you connection string";

        static int totalThreads = 10;

        static int recordsPerThread = 100;

        static object obj = new object();

        static void Main(string[] args)

        {

            // Create an array of threads

            Thread[] threads = new Thread[totalThreads];

​

            // Start each thread

            for (int i = 0; i < totalThreads; i++)

            {

                threads[i] = new Thread(InsertData);

                threads[i].Start(i + 1); // Pass the thread number as a parameter

            }

​

            // Wait for all threads to complete

            foreach (Thread thread in threads)

            {

                thread.Join();

            }

​

            Console.WriteLine("Data insertion completed. Press any key to exit.");

            Console.ReadKey();

        }

​

        static void InsertData(object threadNumber)

        {

            int threadId = (int)threadNumber;

            int startId = (threadId - 1) * recordsPerThread + 1;

            int endId = threadId * recordsPerThread;

            Console.WriteLine($"Thread {threadId} Started...");

            try

            {

                //lock (obj)

                {

                    using (SqlConnection connection = new SqlConnection(connectionString))

                    {

                        connection.Open();

                        for (int i = startId; i <= endId; i++)

                        {

​

                            using (SqlCommand command = connection.CreateCommand())

                            {

                                //command.CommandText = "INSERT INTO imas.PowderEvent (PowderID, Text, InternalText, Value) OUTPUT Inserted.ID VALUES (@PowderId, @Text, '', @Value)";

                                command.CommandText = "INSERT INTO imas.PowderEvent (PowderID, Text, InternalText, Value) VALUES (@PowderId, @Text, '', @Value); SELECT SCOPE_IDENTITY();";

                                //@StationID, @HeatPhaseID, @EventType, @Text, @PowerPhaseID

                                command.Parameters.AddWithValue("@PowderId", 13000);

                                command.Parameters.AddWithValue("@Text", $"Data from Thread {threadId}");

                                command.Parameters.AddWithValue("@Value", i * 10.0);

​

                                int insertedId = Convert.ToInt32(command.ExecuteScalar());

                                Console.WriteLine($"Thread :{threadId} Insert in ID: {insertedId} ");

                            }

​

                        }

                    }

                }

                Console.WriteLine($"Thread {threadId} completed.");

            }

            catch (Exception e)

            {

                Console.WriteLine($"Thread {threadId} Error :{e} ");

            }

​

​

​

        }

    }

}