TaskPoolSerializer

Utility functions for loading and dumping task pools for preserving tasks between application restarts.

class TaskPoolSerializer {

import ocean.meta.types.Qualifiers;;

DE[] concat(DE[] dest, T arrays) via import ocean.core.Array : concat;;

import ocean.core.Enforce;;

import ocean.core.TypeConvert;;

import ocean.meta.traits.Aggregates;;

import ocean.io.device.File;;

import ocean.io.model.IConduit;;

import ocean.io.FilePath;;

import ocean.io.serialize.SimpleStreamSerializer;;

import ocean.task.Task;;

size_t dump(TaskPoolT task_pool, cstring dump_file_path);

size_t dump(TaskPoolT task_pool, OutputStream stream);

size_t load(TaskPoolT task_pool, cstring load_file_path, Args args);

size_t load(TaskPoolT task_pool, InputStream stream, Args args);

}

Members

Functions

dump size_t dump(TaskPoolT task_pool, cstring dump_file_path): Dump the current contents of the task pool to disk. If the task pool is empty then no file will be created.
dump size_t dump(TaskPoolT task_pool, OutputStream stream): Dump the current contents of the task pool to the output stream.
load size_t load(TaskPoolT task_pool, cstring load_file_path, Args args): Loads serialized tasks from disk. Does nothing if no file exists.
load size_t load(TaskPoolT task_pool, InputStream stream, Args args): Restores tasks from the InputStream to the TaskPool.

Meta

Source

See Implementation

ocean task util TaskPoolSerializer classes

TaskPoolSerializer