Gpseq is a parallelism library for Vala and GObject.
using Gpseq;
void main () {
string[] array = {"dog", "cat", "pig", "boar", "bear"};
Seq.of_array<string>(array)
.parallel()
.filter(g => g.length == 3)
.map<string>(g => g.up())
.foreach(g => print("%s\n", g))
.wait();
}
// (possibly unordered) output:
// DOG
// CAT
// PIGusing Gpseq;
void main () {
Channel<string> chan = Channel.bounded<string>(0);
run( () => chan.send("ping").ok() );
print("%s\n", chan.recv().value);
}
// output:
// ping- Work-stealing task scheduling with managed blocking
- Functional programming for data processing with parallel execution support (Seq)
- Unbuffered, buffered, and unbounded MPMC channels
- Fork-join parallelism
- Parallel sorting
- Futures and promises
- 64-bit atomic operations
- Overflow safe arithmetic functions for signed integers
- ...
Read wiki, valadoc, and gtkdoc (C API).
There is a developer's guide in the wiki.
See the installation guide.
Gpseq is released under the LGPL 3.0 license.
Gpseq uses a modified version of timsort.vala of libgee. See TimSort.vala and COPYING-libgee.
