47 lines
2.1 KiB
C++
47 lines
2.1 KiB
C++
#include <render_3D/Render_3D.hpp>
|
|
#include "task_flow/src/Task_Runtime.hpp"
|
|
#include <cstdlib>
|
|
#include <memory>
|
|
#include <process.h>
|
|
namespace {
|
|
using namespace aethera;
|
|
using namespace aethera::render_3d;
|
|
|
|
struct Publish_Context final {
|
|
aethera::render_3d::detail::Prepared_Visual prepared{}; /* Taskflow Visual 节点发布、本次 completion 读取。 */
|
|
std::size_t slot{};
|
|
};
|
|
|
|
void publish(void* raw_context, std::size_t slot, const aethera::render_3d::detail::Prepared_Visual& prepared) {
|
|
if (!raw_context) return;
|
|
auto& context = *static_cast<Publish_Context*>(raw_context);
|
|
context.prepared = prepared;
|
|
context.slot = slot;
|
|
}
|
|
} // namespace
|
|
|
|
int main() {
|
|
if (initialize_task_runtime(2) != Initialize_Task_Runtime_Result::initialized) return 2;
|
|
Point_Visual::Builder builder;
|
|
builder
|
|
.set<Point_Visual::Frame_Tag>([](Point_Visual::Frame& frame) { frame.items = {Point{.diameter_px = 12.0F}}; });
|
|
auto visual = std::shared_ptr<Point_Visual>{builder.build()};
|
|
auto renderable = model_proxy_shared<aethera::render_3d::scene::Renderable>(visual);
|
|
auto context = std::make_shared<Publish_Context>();
|
|
renderable->render(context, 0, &publish);
|
|
renderable->advance();
|
|
|
|
auto component = renderable->taskflow();
|
|
auto graph = task_flow::make_task_graph("render_3d.async_visual_contract");
|
|
if (!graph->compose("point", component)) return 2;
|
|
const auto submitted = graph->run([visual = std::move(visual), context = std::move(context)](std::exception_ptr failure) {
|
|
bool state_valid{};
|
|
visual->get<State_Tag>([&](const Point_Visual::State& state) { state_valid = state.item_count == 1 && state.prepared_item_count == 1 && state.prepared_revision != 0; });
|
|
const bool prepared_valid = context->slot == 0 && context->prepared.has_payload() && context->prepared.item_count() == 1;
|
|
std::_Exit(!failure && state_valid && prepared_valid ? 0 : 1);
|
|
});
|
|
if (submitted != Run_Taskflow_Result::submitted) return 2;
|
|
_endthreadex(3);
|
|
return 3;
|
|
}
|