examples/cpp/exec-threads/s4u-exec-threads.cpp

   1 /* Copyright (c) 2017-2022. The SimGrid Team. All rights reserved.          */
   2
   3 /* This program is free software; you can redistribute it and/or modify it
   4  * under the terms of the license (GNU LGPL) which comes with this package. */
   5
   6 #include <simgrid/s4u.hpp>
   7
   8 XBT_LOG_NEW_DEFAULT_CATEGORY(s4u_exec_thread, "Messages specific for this s4u example");
   9
  10 namespace sg4 = simgrid::s4u;
  11
  12 static void runner()
  13 {
  14   auto e                    = sg4::Engine::get_instance();
  15   sg4::Host* multicore_host = e->host_by_name("MyHost1");
  16   // First test with less than, same number as, and more threads than cores
  17   double start_time = sg4::Engine::get_clock();
  18   sg4::this_actor::thread_execute(multicore_host, 1e9, 2);
  19   XBT_INFO("Computed 2-thread activity on a 4-core host. Took %g s", e->get_clock() - start_time);
  20
  21   start_time = sg4::Engine::get_clock();
  22   sg4::this_actor::thread_execute(multicore_host, 1e9, 4);
  23   XBT_INFO("Computed 4-thread activity on a 4-core host. Took %g s", e->get_clock() - start_time);
  24
  25   start_time = sg4::Engine::get_clock();
  26   sg4::this_actor::thread_execute(multicore_host, 1e9, 6);
  27   XBT_INFO("Computed 6-thread activity on a 4-core host. Took %g s", e->get_clock() - start_time);
  28
  29   simgrid::s4u::ExecPtr background_task = sg4::this_actor::exec_async(2.5e9);
  30   XBT_INFO("Start a 1-core background task on the 4-core host.");
  31
  32   start_time = sg4::Engine::get_clock();
  33   sg4::this_actor::thread_execute(multicore_host, 1e9, 2);
  34   XBT_INFO("Computed 2-thread activity on a 4-core host. Took %g s", e->get_clock() - start_time);
  35
  36   start_time = sg4::Engine::get_clock();
  37   sg4::this_actor::thread_execute(multicore_host, 1e9, 4);
  38   XBT_INFO("Computed 4-thread activity on a 4-core host. Took %g s", e->get_clock() - start_time);
  39
  40   background_task->wait();
  41   XBT_INFO("The background task has ended.");
  42
  43   background_task = sg4::this_actor::exec_init(2e9)->set_thread_count(4)->start();
  44   XBT_INFO("Start a 4-core background task on the 4-core host.");
  45
  46   XBT_INFO("Sleep for 5 seconds before starting another competing task");
  47   sg4::this_actor::sleep_for(5);
  48
  49   start_time = sg4::Engine::get_clock();
  50   sg4::this_actor::execute(1e9);
  51   XBT_INFO("Computed 1-thread activity on a 4-core host. Took %g s", e->get_clock() - start_time);
  52
  53   background_task->wait();
  54   XBT_INFO("The background task has ended.");
  55 }
  56
  57 int main(int argc, char* argv[])
  58 {
  59   sg4::Engine e(&argc, argv);
  60
  61   xbt_assert(argc == 2, "Usage: %s <platform file>", argv[0]);
  62
  63   e.load_platform(argv[1]);
  64   sg4::Actor::create("test", e.host_by_name("MyHost1"), runner);
  65
  66   e.run();
  67   XBT_INFO("Simulation done.");
  68   return 0;
  69 }