You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vo...@apache.org on 2016/11/17 10:51:43 UTC
[20/50] [abbrv] ignite git commit: IGNITE-4118 .NET: Optimistic
transaction example
IGNITE-4118 .NET: Optimistic transaction example
This closes #1200
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/df670c7d
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/df670c7d
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/df670c7d
Branch: refs/heads/ignite-2693
Commit: df670c7d64046d282c053f296c47a4743c58c8b1
Parents: ead1519
Author: Pavel Tupitsyn <pt...@apache.org>
Authored: Mon Nov 7 12:40:00 2016 +0300
Committer: Pavel Tupitsyn <pt...@apache.org>
Committed: Mon Nov 7 12:40:00 2016 +0300
----------------------------------------------------------------------
.../Apache.Ignite.Examples.csproj | 1 +
.../Datagrid/OptimisticTransactionExample.cs | 110 +++++++++++++++++++
2 files changed, 111 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/df670c7d/modules/platforms/dotnet/examples/Apache.Ignite.Examples/Apache.Ignite.Examples.csproj
----------------------------------------------------------------------
diff --git a/modules/platforms/dotnet/examples/Apache.Ignite.Examples/Apache.Ignite.Examples.csproj b/modules/platforms/dotnet/examples/Apache.Ignite.Examples/Apache.Ignite.Examples.csproj
index 9b1d323..2ee91da 100644
--- a/modules/platforms/dotnet/examples/Apache.Ignite.Examples/Apache.Ignite.Examples.csproj
+++ b/modules/platforms/dotnet/examples/Apache.Ignite.Examples/Apache.Ignite.Examples.csproj
@@ -52,6 +52,7 @@
<Compile Include="Compute\TaskExample.cs" />
<Compile Include="Datagrid\ContinuousQueryExample.cs" />
<Compile Include="Datagrid\DataStreamerExample.cs" />
+ <Compile Include="Datagrid\OptimisticTransactionExample.cs" />
<Compile Include="Datagrid\PutGetExample.cs" />
<Compile Include="Datagrid\LinqExample.cs" />
<Compile Include="Datagrid\BinaryModeExample.cs" />
http://git-wip-us.apache.org/repos/asf/ignite/blob/df670c7d/modules/platforms/dotnet/examples/Apache.Ignite.Examples/Datagrid/OptimisticTransactionExample.cs
----------------------------------------------------------------------
diff --git a/modules/platforms/dotnet/examples/Apache.Ignite.Examples/Datagrid/OptimisticTransactionExample.cs b/modules/platforms/dotnet/examples/Apache.Ignite.Examples/Datagrid/OptimisticTransactionExample.cs
new file mode 100644
index 0000000..2f9d164
--- /dev/null
+++ b/modules/platforms/dotnet/examples/Apache.Ignite.Examples/Datagrid/OptimisticTransactionExample.cs
@@ -0,0 +1,110 @@
+\ufeff/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+using System;
+using System.Threading;
+using System.Threading.Tasks;
+using Apache.Ignite.Core;
+using Apache.Ignite.Core.Cache;
+using Apache.Ignite.Core.Cache.Configuration;
+using Apache.Ignite.Core.Transactions;
+
+namespace Apache.Ignite.Examples.Datagrid
+{
+ /// <summary>
+ /// This example demonstrates optimistic transaction concurrency control.
+ /// <para />
+ /// 1) Build the project Apache.Ignite.ExamplesDll (select it -> right-click -> Build).
+ /// Apache.Ignite.ExamplesDll.dll must appear in %IGNITE_HOME%/platforms/dotnet/examples/Apache.Ignite.ExamplesDll/bin/${Platform]/${Configuration} folder.
+ /// 2) Set this class as startup object (Apache.Ignite.Examples project -> right-click -> Properties ->
+ /// Application -> Startup object);
+ /// 3) Start example (F5 or Ctrl+F5).
+ /// <para />
+ /// This example can be run with standalone Apache Ignite.NET node:
+ /// 1) Run %IGNITE_HOME%/platforms/dotnet/bin/Apache.Ignite.exe:
+ /// Apache.Ignite.exe -configFileName=platforms\dotnet\examples\apache.ignite.examples\app.config -assembly=[path_to_Apache.Ignite.ExamplesDll.dll]
+ /// 2) Start example.
+ /// </summary>
+ public class OptimisticTransactionExample
+ {
+ /// <summary>Cache name.</summary>
+ private const string CacheName = "dotnet_optimistic_tx_example";
+
+ [STAThread]
+ public static void Main()
+ {
+ using (var ignite = Ignition.StartFromApplicationConfiguration())
+ {
+ Console.WriteLine();
+ Console.WriteLine(">>> Optimistic transaction example started.");
+
+ // Create Transactional cache.
+ var cacheCfg = new CacheConfiguration(CacheName) { AtomicityMode = CacheAtomicityMode.Transactional };
+
+ var cache = ignite.GetOrCreateCache<int, int>(cacheCfg);
+
+ // Put a value.
+ cache[1] = 0;
+
+ // Increment a value in parallel within a transaction.
+ var task1 = Task.Factory.StartNew(() => IncrementCacheValue(cache, 1));
+ var task2 = Task.Factory.StartNew(() => IncrementCacheValue(cache, 2));
+
+ Task.WaitAll(task1, task2);
+
+ Console.WriteLine();
+ Console.WriteLine(">>> Resulting value in cache: " + cache[1]);
+
+ Console.WriteLine();
+ Console.WriteLine(">>> Example finished, press any key to exit ...");
+ Console.ReadKey();
+ }
+ }
+
+ /// <summary>
+ /// Increments the cache value within a transaction.
+ /// </summary>
+ /// <param name="cache">The cache.</param>
+ /// <param name="threadId">The thread identifier.</param>
+ private static void IncrementCacheValue(ICache<int, int> cache, int threadId)
+ {
+ try
+ {
+ var transactions = cache.Ignite.GetTransactions();
+
+ using (var tx = transactions.TxStart(TransactionConcurrency.Optimistic,
+ TransactionIsolation.Serializable))
+ {
+ // Increment cache value.
+ cache[1]++;
+
+ // Introduce a delay to ensure lock conflict.
+ Thread.Sleep(TimeSpan.FromSeconds(2.5));
+
+ tx.Commit();
+ }
+
+ Console.WriteLine("\n>>> Thread {0} successfully incremented cached value.", threadId);
+ }
+ catch (TransactionOptimisticException ex)
+ {
+ Console.WriteLine("\n>>> Thread {0} failed to increment cached value. " +
+ "Caught an expected optimistic exception: {1}", threadId, ex.Message);
+ }
+ }
+ }
+}
\ No newline at end of file