.net framework support 人大金仓

2025-09-22 12:09:29 +08:00 · 2023-01-17 23:34:29 +08:00
parent 4a6be929be
commit 3b160e347c
72 changed files with 5979 additions and 8 deletions
--- a/Src/Asp.Net/KdbndpTest/UnitTest/UThread3.cs
+++ b/Src/Asp.Net/KdbndpTest/UnitTest/UThread3.cs
@@ -0,0 +1,117 @@
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OrmTest
+{
+    public partial class NewUnitTest
+    {
+
+        public static void Thread3()
+        {
+            Console.WriteLine("Thread3");
+            SimpleAsync3().Wait();
+            IsShardSameThreadAsync3().Wait();
+            SingleAsync3().Wait();
+            SingleAndIsShardSameThreadAsync3().Wait();
+
+        }
+
+
+
+        private static async Task SimpleAsync3()
+        {
+
+            for (int i = 0; i < 100; i++)
+            {
+                await simpleDb.Queryable<Order>().Take(10).ToListAsync();
+            }
+
+            for (int i = 0; i < 100; i++)
+            {
+                await simpleDb.Insertable(new Order() { Name = "a", CustomId = 1 }).ExecuteCommandAsync();
+            }
+
+            List<Order> orders = new List<Order>();
+            for (int i = 0; i < 100; i++)
+            {
+                orders = await simpleDb.Queryable<Order>().Take(10).ToListAsync();
+            }
+            if (orders.Count > 0)
+            {
+                Console.WriteLine("async is ok");
+            }
+        }
+
+        private static async Task SingleAndIsShardSameThreadAsync3()
+        {
+            for (int i = 0; i < 100; i++)
+            {
+                await singleAndSsDb.Queryable<Order>().Take(10).ToListAsync();
+            }
+
+            for (int i = 0; i < 100; i++)
+            {
+                await singleAndSsDb.Insertable(new Order() { Name = "a", CustomId = 1 }).ExecuteCommandAsync();
+            }
+            List<Order> orders = new List<Order>();
+            for (int i = 0; i < 100; i++)
+            {
+                orders = await singleAndSsDb.Queryable<Order>().Take(10).ToListAsync();
+            }
+            if (orders.Count > 0)
+            {
+                Console.WriteLine("async is ok");
+            }
+        }
+
+        private static async Task SingleAsync3()
+        {
+            for (int i = 0; i < 100; i++)
+            {
+                await singleDb.Queryable<Order>().Take(10).ToListAsync();
+            }
+
+            for (int i = 0; i < 100; i++)
+            {
+                await singleDb.Insertable(new Order() { Name = "a", CustomId = 1 }).ExecuteCommandAsync();
+            }
+
+            List<Order> orders = new List<Order>();
+            for (int i = 0; i < 100; i++)
+            {
+                orders = await singleDb.Queryable<Order>().Take(10).ToListAsync();
+            }
+            if (orders.Count > 0)
+            {
+                Console.WriteLine("async is ok");
+            }
+        }
+
+        private static async Task IsShardSameThreadAsync3()
+        {
+            for (int i = 0; i < 100; i++)
+            {
+                await ssDb.Queryable<Order>().Take(10).ToListAsync();
+            }
+
+            for (int i = 0; i < 100; i++)
+            {
+                await ssDb.Insertable(new Order() { Name = "a", CustomId = 1 }).ExecuteCommandAsync();
+            }
+
+            List<Order> orders = new List<Order>();
+            for (int i = 0; i < 100; i++)
+            {
+                orders = await ssDb.Queryable<Order>().Take(10).ToListAsync();
+            }
+            if (orders.Count > 0)
+            {
+                Console.WriteLine("async is ok");
+            }
+        }
+    }
+}