DtCraft是一種基于數(shù)據(jù)并行流的通用分布式編程系統(tǒng)。 它提供了一種稱為流圖的新型強(qiáng)大編程模型，用于構(gòu)建并行和分布式工作負(fù)載。 將應(yīng)用程序轉(zhuǎn)換為此框架后，內(nèi)核將透明地為您執(zhí)行作業(yè)分發(fā)。 您不必?fù)?dān)心系統(tǒng)編程，可以專注于高級開發(fā)！

無論您是應(yīng)用程序開發(fā)人員還是特定領(lǐng)域的工程師，都可以使用 DtCraft 來做：

• 分布式編程 Distributed computing
• 事件驅(qū)動編程 Event-driven programming
• 網(wǎng)絡(luò)編程 Network programming
• 數(shù)據(jù)流處理 Data stream processing

示例代碼：

#include 
  
using namespace std::literals;  // for the use of string literal
using namespace dtc::literals;  // for the use of memory literal

int main(int argc, char* argv[]) {

  dtc::Graph G;

  auto A = G.vertex();
  auto B = G.vertex();

  auto lambda = [] (dtc::Vertex& v, dtc::InputStream& is) {
    if(std::string s; is(s) != -1) {
      std::cout << "Received: " << s << '\n';
      return dtc::Event::REMOVE;
    }
    return dtc::Event::DEFAULT;
  };

  auto AB = G.stream(A, B).on(lambda);
  auto BA = G.stream(B, A).on(lambda); 

  A.on([&AB] (dtc::Vertex& v) { (*v.ostream(AB))("hello world from A"s); });  
  B.on([&BA] (dtc::Vertex& v) { (*v.ostream(BA))("hello world from B"s); });
  
  G.container().add(A).cpu(1).memory(1_GB);
  G.container().add(B).cpu(1).memory(1_GB);

  dtc::Executor(G).run();
}

?