release130.19

Author: tradercjz

README_CN.md

@@ -0,0 +1,16 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFramework>netcoreapp3.1</TargetFramework>
+    <AllowUnsafeBlocks>True</AllowUnsafeBlocks>
+	<GenerateAssemblyInfo>false</GenerateAssemblyInfo>
+	<AssemblyName>dolphindb_csharpapi</AssemblyName>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <Compile Remove="test\**" />
+    <EmbeddedResource Remove="test\**" />
+    <None Remove="test\**" />
+  </ItemGroup>
+
+</Project>

dolphindb_csharpapi_net_core.csproj

@@ -0,0 +1,34 @@
+
+Microsoft Visual Studio Solution File, Format Version 12.00
+# Visual Studio Version 17
+VisualStudioVersion = 17.1.32210.238
+MinimumVisualStudioVersion = 10.0.40219.1
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "dolphindb_csharpapi_net_core", "dolphindb_csharpapi_net_core.csproj", "{5233ED95-F919-4FA3-8BD9-193E066A8F27}"
+EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "dolphindb_csharpapi_net_core_test", "test\dolphindb_csharpapi_net_core_test.csproj", "{6D88F097-9FEC-4636-BBA6-A3E59DB0BB7E}"
+	ProjectSection(ProjectDependencies) = postProject
+		{5233ED95-F919-4FA3-8BD9-193E066A8F27} = {5233ED95-F919-4FA3-8BD9-193E066A8F27}
+	EndProjectSection
+EndProject
+Global
+	GlobalSection(SolutionConfigurationPlatforms) = preSolution
+		Debug|Any CPU = Debug|Any CPU
+		Release|Any CPU = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(ProjectConfigurationPlatforms) = postSolution
+		{5233ED95-F919-4FA3-8BD9-193E066A8F27}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{5233ED95-F919-4FA3-8BD9-193E066A8F27}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{5233ED95-F919-4FA3-8BD9-193E066A8F27}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{5233ED95-F919-4FA3-8BD9-193E066A8F27}.Release|Any CPU.Build.0 = Release|Any CPU
+		{6D88F097-9FEC-4636-BBA6-A3E59DB0BB7E}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{6D88F097-9FEC-4636-BBA6-A3E59DB0BB7E}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{6D88F097-9FEC-4636-BBA6-A3E59DB0BB7E}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{6D88F097-9FEC-4636-BBA6-A3E59DB0BB7E}.Release|Any CPU.Build.0 = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(SolutionProperties) = preSolution
+		HideSolutionNode = FALSE
+	EndGlobalSection
+	GlobalSection(ExtensibilityGlobals) = postSolution
+		SolutionGuid = {FB1A5801-604F-4CB4-B4AB-ED370B77C83F}
+	EndGlobalSection
+EndGlobal

dolphindb_csharpapi_net_core.sln

@@ -112,6 +112,11 @@ public void doEvent(IMessage msg)
             double price = ((BasicDouble)msg.getEntity(4)).getValue();
             Console.WriteLine("price:" + price + " \n");
         }
+
+        void MessageHandler.batchHandler(List<IMessage> msgs)
+        {
+            throw new NotImplementedException();
+        }
     }
 
     public void ThreadedClient()

examples/StreamingData.cs

@@ -20,22 +20,25 @@ public class BasicDBTask:IDBTask
         private List<IEntity> args;
         private DBConnection conn;
         private WaitHandle waitHandle = new AutoResetEvent(false);
+        private Semaphore semaphore = new Semaphore(1,1);
 
-        public WaitHandle WaitFor()
+        public void waitFor()
         {
-            return waitHandle;
+            semaphore.WaitOne();
         }
-        public void Finish()
+        public void finish()
         {
-            ((AutoResetEvent)waitHandle).Set();
+            semaphore.Release();
         }
         public BasicDBTask(string script, List<IEntity> args)
         {
+            semaphore.WaitOne();
             this.script = script;
             this.args = args;
         }
         public BasicDBTask(string script)
         {
+            semaphore.WaitOne();
             this.script = script;
         }
         public IEntity call()
@@ -74,5 +77,17 @@ public bool isSuccessful()
         {
             return successful;
         }
+
+        public bool isFinished()
+        {
+            if(successful || errMsg != null)
+            {
+                return true;
+            }
+            else
+            {
+                return false;
+            }
+        }
     }
 }