#include <condition_variable>
#include <iostream>
#include <mutex>
#include <thread>

std::mutex mtx;
std::condition_variable cv;
int ready_thread_id = 0;
int signal_main_thread = 0;

void worker(int id) {
  std::cout << "Worker " << id << " executing..." << std::endl;

  // lldb test should change signal_main_thread to true to break the loop.
  while (!signal_main_thread) {
    std::this_thread::sleep_for(std::chrono::milliseconds(10));
  }

  // Signal the main thread to continue main thread
  {
    std::lock_guard<std::mutex> lock(mtx);
    ready_thread_id = id; // break worker thread here
  }
  cv.notify_one();

  std::this_thread::sleep_for(std::chrono::seconds(1));
  std::cout << "Worker " << id << " finished." << std::endl;
}

void deadlock_func(std::unique_lock<std::mutex> &lock) {
  int i = 10;
  ++i;             // Set interrupt breakpoint here
  printf("%d", i); // Finish step-over from inner breakpoint
  auto func = [] { return ready_thread_id == 1; };
  cv.wait(lock, func);
}

int simulate_thread() {
  std::thread t1(worker, 1);

  std::unique_lock<std::mutex> lock(mtx);
  deadlock_func(lock); // Set breakpoint1 here

  std::thread t2(worker, 2); // Finish step-over from breakpoint1

  cv.wait(lock, [] { return ready_thread_id == 2; });

  t1.join();
  t2.join();

  std::cout << "Main thread continues..." << std::endl;

  return 0;
}

int bar() { return 54; }

int foo(const std::string p1, int extra) { return p1.size() + extra; }

int main(int argc, char *argv[]) {
  std::string ss = "this is a string for testing",
              ls = "this is a long string for testing";
  foo(ss.size() % 2 == 0 ? ss : ls, bar()); // Set breakpoint2 here

  simulate_thread(); // Finish step-over from breakpoint2

  return 0;
}