Основные операции с кешем#

IIgnite ignite = Ignition.Start();  

// Получите экземпляр кеша `myCache`.
// Аргументы дженериков (generics) используются только для удобства пользователя.
// Можно работать с любым кешем в контексте аргументов дженериков.
// Попытка получить запись несовместимого типа
// приведет к исключению.
ICache<int, string> cache = ignite.GetCache<int, string>("myCache");

IIgnite ignite = Ignition.Start();  

// Создать кеш с указанным названием, если его еще нет.
var cache = ignite.GetOrCreateCache<int, string>("myNewCache");

IgniteConfiguration cfg;
cfg.springCfgPath = "/path/to/configuration.xml";

try
{
    Ignite ignite = Ignition::Start(cfg);

    Cache<int32_t, std::string> cache = ignite.GetOrCreateCache<int32_t, std::string>(CACHE_NAME);

	// Храните ключи в кеше (значения окажутся на разных узлах кеша).
    for (int32_t i = 0; i < 10; i++)
    {
        cache.Put(i, std::to_string(i));
    }

    for (int i = 0; i < 10; i++)
    {
        std::cout << "Got [key=" << i << ", val=" + cache.Get(i) << "]" << std::endl;
    }
}
catch (IgniteError& err)
{
    std::cout << "An error occurred: " << err.GetText() << std::endl;
    return err.GetCode();
}

IgniteConfiguration cfg;
cfg.springCfgPath = "/path/to/configuration.xml";

Ignite ignite = Ignition::Start(cfg);

Cache<std::string, int32_t> cache = ignite.GetOrCreateCache<std::string, int32_t>("myNewCache");  

// Операция `put-if-absent` возвращает предыдущее значение.
int32_t oldVal = cache.GetAndPutIfAbsent("Hello", 11);  

// Операция `put-if-absent` возвращает логический флаг успешного выполнения.
boolean success = cache.PutIfAbsent("World", 22);

// Операция `replace-if-exists` (противоположная для `getAndPutIfAbsent`) возвращает предыдущее
// значение.
 oldVal = cache.GetAndReplace("Hello", 11);

// Операция `replace-if-exists` (противоположная операции `putIfAbsent`) возвращает логический флаг
// успешного выполнения.
success = cache.Replace("World", 22);

// Операция `replace-if-matches`.
success = cache.Replace("World", 2, 22);

// Операция `remove-if-matches`.
success = cache.Remove("Hello", 1);

// Синхронный метод `get`.
V Get(K key);

// Асинхронный метод `get`.
Future<V> GetAsync(K key);

/*
 * Функциональный класс.
 */
class HelloWorld : public compute::ComputeFunc<void>
{
    friend struct ignite::binary::BinaryType<HelloWorld>;
public:
    /*
     * Конструктор по умолчанию.
     */
    HelloWorld()
    {
        // Без операции.
    }

    /**
     * Обратный вызов.
     */
    virtual void Call()
    {
        std::cout << "Job Result: Hello World" << std::endl;
    }

};

/**
 * Структура бинарного типа. Определяет набор функций, которые нужны для сериализации и десериализации типа.
 */
namespace ignite
{
    namespace binary
    {
        template<>
        struct BinaryType<HelloWorld>
        {
            static int32_t GetTypeId()
            {
                return GetBinaryStringHashCode("HelloWorld");
            }

            static void GetTypeName(std::string& dst)
            {
                dst = "HelloWorld";
            }

            static int32_t GetFieldId(const char* name)
            {
                return GetBinaryStringHashCode(name);
            }

            static int32_t GetHashCode(const HelloWorld& obj)
            {
                return 0;
            }

            static bool IsNull(const HelloWorld& obj)
            {
                return false;
            }

            static void GetNull(HelloWorld& dst)
            {
                dst = HelloWorld();
            }

            static void Write(BinaryWriter& writer, const HelloWorld& obj)
            {
                // Без операции.
            }

            static void Read(BinaryReader& reader, HelloWorld& dst)
            {
                // Без операции.
            }
        };
    }
}

int main()
{
    IgniteConfiguration cfg;
    cfg.springCfgPath = "/path/to/configuration.xml";

    Ignite ignite = Ignition::Start(cfg);

    // Получите связующий экземпляр.
    IgniteBinding binding = ignite.GetBinding();

    // Зарегистрируйте класс в качестве вычислительной функции.
    binding.RegisterComputeFunc<HelloWorld>();

    // Получите экземпляр вычислений.
    compute::Compute compute = ignite.GetCompute();

    // Объявите экземпляр функции.
    HelloWorld helloWorld;

    // Сделайте асинхронный вызов.
    compute.RunAsync(helloWorld);
}