Changeset d25b2d6 for libcfa/src/concurrency

Timestamp:

Dec 16, 2020, 3:43:34 PM (3 years ago)

Author:

Colby Alexander Parsons <caparsons@…>

Branches:

ADT, arm-eh, ast-experimental, enum, forall-pointer-decay, jacob/cs343-translation, master, new-ast-unique-expr, pthread-emulation, qualifiedEnum

Children:

8a81b09

Parents:

c131a02

Message:

small cleanup

Location:

libcfa/src/concurrency

Files:

• invoke.h (modified) (1 diff)
• locks.cfa (modified) (1 diff)

libcfa/src/concurrency/invoke.h

@@ -18 +18 @@
 #include "bits/locks.hfa"
 #include "kernel/fwd.hfa"
-#include <stddef.h>
 
 #ifdef __cforall

libcfa/src/concurrency/locks.cfa

@@ -364 +364 @@
         }
 }
-
-// const unsigned int num_times = 50000;
-
-// multiple_acquisition_lock m;
-// condition_variable( multiple_acquisition_lock ) c_m;
-
-// single_acquisition_lock s;
-// condition_variable( single_acquisition_lock ) c_s;
-
-// owner_lock o;
-// condition_variable( owner_lock ) c_o;
-
-// thread T_C_M_WS1 {};
-
-// void main( T_C_M_WS1 & this ) {
-//      fprintf(stderr, "start of thd main listed: %d\n", listed(active_thread()) );
-//      fprintf(stderr, "thread colable next ptr in start of thd main %p\n", Next( (Colable *)active_thread() ) );
-//      for (unsigned int i = 0; i < num_times; i++) {
-//              lock(m);
-//              if(empty(c_m) && i != num_times - 1) {
-//                      wait(c_m,m);
-//              }else{
-//                      notify_one(c_m);
-//              }
-//              unlock(m);
-//      }
-// }
-
-// thread T_C_M_WB1 {};
-
-// void main( T_C_M_WB1 & this ) {
-//      for (unsigned int i = 0; i < num_times; i++) {
-//              lock(m);
-//              if(counter(c_m) == 3 || i == num_times - 1) {
-//                      notify_all(c_m);
-//              }else{
-//                      wait(c_m,m);
-//              }
-//              unlock(m);
-//      }
-// }
-
-// thread T_C_S_WS1 {};
-
-// void main( T_C_S_WS1 & this ) {
-//      for (unsigned int i = 0; i < num_times; i++) {
-//              lock(s);
-//              if(empty(c_s) && i != num_times - 1) {
-//                      wait(c_s,s);
-//              }else{
-//                      notify_one(c_s);
-//              }
-//              unlock(s);
-//      }
-// }
-
-// thread T_C_S_WB1 {};
-
-// void main( T_C_S_WB1 & this ) {
-//      for (unsigned int i = 0; i < num_times; i++) {
-//              lock(s);
-//              if(counter(c_s) == 3 || i == num_times - 1) {
-//                      notify_all(c_s);
-//              }else{
-//                      wait(c_s,s);
-//              }
-//              unlock(s);
-//      }
-// }
-
-// thread T_C_O_WS1 {};
-
-// void main( T_C_O_WS1 & this ) {
-//      for (unsigned int i = 0; i < num_times; i++) {
-//              lock(o);
-//              if(empty(c_o) && i != num_times - 1) {
-//                      wait(c_o,o);
-//              }else{
-//                      notify_one(c_o);
-//              }
-//              unlock(o);
-//      }
-// }
-
-// thread T_C_O_WB1 {};
-
-// void main( T_C_O_WB1 & this ) {
-//      for (unsigned int i = 0; i < num_times; i++) {
-//              lock(o);
-//              if(counter(c_o) == 3 || i == num_times - 1) {
-//                      notify_all(c_o);
-//              }else{
-//                      wait(c_o,o);
-//              }
-//              unlock(o);
-//      }
-// }
-
-// thread T_C_M_WS2 {};
-
-// void main( T_C_M_WS2 & this ) {
-//      for (unsigned int i = 0; i < num_times; i++) {
-//              lock(m);
-//              lock(m);
-//              lock(m);
-//              if(empty(c_m) && i != num_times - 1) {
-//                      wait(c_m,m);
-//              }else{
-//                      notify_one(c_m);
-//              }
-//              unlock(m);
-//              unlock(m);
-//              unlock(m);
-//      }
-// }
-
-// thread T_C_O_WS2 {};
-
-// void main( T_C_O_WS2 & this ) {
-//      for (unsigned int i = 0; i < num_times; i++) {
-//              lock(o);
-//              lock(o);
-//              lock(o);
-//              if(empty(c_o) && i != num_times - 1) {
-//                      wait(c_o,o);
-//              }else{
-//                      notify_one(c_o);
-//              }
-//              unlock(o);
-//              unlock(o);
-//              unlock(o);
-//      }
-// }
-
-// thread T_C_NLW {};
-
-// void main( T_C_NLW & this ) {
-//      for (unsigned int i = 0; i < num_times; i++) {
-//              wait(c_o);
-//      }
-// }
-
-// thread T_C_NLS {};
-
-// void main( T_C_NLS & this ) {
-//      for (unsigned int i = 0; i < num_times; i++) {
-//              while (empty(c_o)) { }
-//              notify_one(c_o);
-//      }
-// }
-
-// thread T_C_S_WNF {};
-
-// void main( T_C_S_WNF & this ) {
-//      for (unsigned int i = 0; i < num_times; i++) {
-//              lock(s);
-//              if(empty(c_s) && i != num_times - 1) {
-//                      wait(c_s, s, 10);
-//              }else{
-//                      if(!empty(c_s)) assert(front(c_s) == 10);
-//                      notify_one(c_s);
-//              }
-//              unlock(s);
-//      }
-// }
-
-// bool done = false;
-
-// thread T_C_NLWD {};
-
-// void main( T_C_NLWD & this ) {
-//      done = false;
-//      for (unsigned int i = 0; i < num_times; i++) {
-//              wait(c_s, 1`ns);
-//      }
-//      done = true;
-// }
-
-// thread T_C_WDS {};
-
-// void main( T_C_WDS & this ) {
-//      for (unsigned int i = 0; i < num_times; i++) {
-//              while (empty(c_s) && !done) { }
-//              notify_one(c_s);
-//              sleep(1`ns);
-//              if(done) break;
-//      }
-// }
-
-// thread T_C_LWD {};
-
-// void main( T_C_LWD & this ) {
-//      done = false;
-//      for (unsigned int i = 0; i < num_times; i++) {
-//              if (i % 500 == 0) printf("!! %d\n", i);
-//              lock(s);
-//              wait(c_s, s, 1`ns);
-//              unlock(s);
-//      }
-//      done = true;
-// }
-
-// int main() {
-//      processor p[2];
-//      printf("Start Test 1: multi acquisition lock and condition variable single wait/notify\n");
-//      {
-//              T_C_M_WS1 t1;
-//      }
-//      printf("Done Test 1\n");
-
-//      printf("Start Test 2: multi acquisition lock and condition variable 3 wait/notify all\n");
-//      {
-//              T_C_M_WB1 t1[4];
-//      }
-//      printf("Done Test 2\n");
-
-//      printf("Start Test 3: single acquisition lock and condition variable single wait/notify\n");
-//      {
-//              T_C_S_WS1 t1[2];
-//      }
-//      printf("Done Test 3\n");
-
-//      printf("Start Test 4: single acquisition lock and condition variable 3 wait/notify all\n");
-//      {
-//              T_C_S_WB1 t1[4];
-//      }
-//      printf("Done Test 4\n");
-
-//      printf("Start Test 5: owner lock and condition variable single wait/notify\n");
-//      {
-//              T_C_O_WS1 t1[2];
-//      }
-//      printf("Done Test 5\n");
-
-//      printf("Start Test 6: owner lock and condition variable 3 wait/notify all\n");
-//      {
-//              T_C_O_WB1 t1[4];
-//      }
-//      printf("Done Test 6\n");
-
-//      printf("Start Test 7: multi acquisiton lock and condition variable multiple acquire and wait/notify\n");
-//      {
-//              T_C_M_WS2 t1[2];
-//      }
-//      printf("Done Test 7\n");
-
-//      printf("Start Test 8: owner lock and condition variable multiple acquire and wait/notify\n");
-//      {
-//              T_C_O_WS2 t1[2];
-//      }
-//      printf("Done Test 8\n");
-
-//      printf("Start Test 9: no lock condition variable wait/notify\n");
-//      {
-//              T_C_NLW t1;
-//              T_C_NLS t2;
-//      }
-//      printf("Done Test 9\n");
-
-//      printf("Start Test 10: locked condition variable wait/notify with front()\n");
-//      {
-//              T_C_S_WNF t1[2];
-//      }
-//      printf("Done Test 10\n");
-
-//      printf("Start Test 11: unlocked condition variable delay wait\n");
-//      {
-//              T_C_NLWD t1;
-//              T_C_WDS t2;
-//      }
-//      printf("Done Test 11\n");
-
-//      // printf("Start Test 12: locked condition variable delay wait\n");
-//      // {
-//      //      T_C_LWD t1;
-//      //      T_C_WDS t2;
-//      // }
-//      // printf("Done Test 12\n");
-// }