oreodave/abelian-sandpile
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

(main)+kill threads when avalanche has completed

Browse Source 
After the so-called "avalanche", where the fractal has finished
forming as there are no more candidates for toppling, we no longer
need the threads to be working.  As an intensive operation, it makes
no sense to continue processing when we are sure there is no further
dynamic behaviour possible.

Using a tick based solution, every DELTA ticks we check if the
avalanche is completed.  If so, we clean up all the threads AND ensure
that we no longer need to be checking for avalanches.
This commit is contained in:
Aryadev Chavali
2023-08-27 22:06:44 +01:00
parent 2d11304ab4
commit 65bb0e0f66
1 changed files with 30 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
main.c
View File

@@ -56,9 +56,19 @@ void *compute_thread(void *input)
return NULL;
}
int main(void)
bool completed_avalanche(state_t *state)
{
state_t state = {NULL, 512, 512, 0, true, pow(2, 20)};
for (size_t i = 0; i < state->dwidth; ++i)
for (size_t j = 0; j < state->dwidth; ++j)
if (state->data[(i * state->dwidth) + j] >= 4)
return false;
return true;
}
int main(int argc, char *argv[])
{
// Setup "default" state
state_t state = {NULL, 512, 512, 0, true, pow(2, 16)};
state.data = calloc(state.dwidth * state.dwidth, sizeof(*state.data));
state.multiplier = state.window_len / state.dwidth;
state.data[(state.dwidth * state.dwidth / 2) + (state.dwidth / 2)] =
@@ -85,7 +95,9 @@ int main(void)
InitWindow(state.window_len, state.window_len, "Abelian sand pile");
SetTargetFPS(60);
while (!WindowShouldClose())
const int DELTA = 100;
bool done = false;
for (uint64_t ticks = 0, prev_ticks = 0; !WindowShouldClose(); ++ticks)
{
if (IsKeyPressed(KEY_UP) || IsKeyDown(KEY_UP))
{
@@ -108,6 +120,21 @@ int main(void)
camera.zoom = zoom;
}
if (ticks - prev_ticks > DELTA && !done)
{
printf("Checking if avalanche is complete!\n");
if (completed_avalanche(&state))
{
state.thread_alive = false;
pthread_join(thread_a, NULL);
pthread_join(thread_b, NULL);
pthread_join(thread_c, NULL);
pthread_join(thread_d, NULL);
done = true;
}
prev_ticks = ticks;
}
if (IsMouseButtonDown(MOUSE_BUTTON_LEFT))
{
Vector2 delta = Vector2Scale(GetMouseDelta(), -1.0f / camera.zoom);