os_cp:threads
Differences
This shows you the differences between two versions of the page.
| Both sides previous revisionPrevious revisionNext revision | Previous revision | ||
| os_cp:threads [2025/04/16 19:57] – jkonczak | os_cp:threads [2025/04/25 11:55] (current) – [POSIX condition variables] jkonczak | ||
|---|---|---|---|
| Line 704: | Line 704: | ||
| ===== Critical sections, deadlocks ===== | ===== Critical sections, deadlocks ===== | ||
| - | ~~Exercise.# | + | ~~Exercise.# |
| - | ~~Exercise.# | + | ~~Exercise.# |
| ~~Exercise.# | ~~Exercise.# | ||
| - | < | + | < |
| - | <small> | + | <code c> |
| - | < | + | … |
| - | #include < | + | 10│ struct myIO {FILE *in; FILE *out;}; |
| - | #include < | + | 11│ void* threadFunc(void *num); |
| - | #include < | + | … |
| - | #include < | + | 17│ struct { |
| - | #include < | + | 18│ pthread_mutex_t mtx; |
| - | + | 19│ char text[256]; | |
| - | struct { | + | 20│ } item[5]; |
| - | pthread_mutex_t mtx; | + | 21│ |
| - | char text[256]; | + | 22│ int main(int argc, char **argv) { |
| - | } item[5]; | + | … |
| - | + | 28│ | |
| - | const char *arg0; | + | 29│ |
| - | + | 30│ | |
| - | void *threadFunc(intptr_t | + | 31│ |
| - | char name[1024], cmd[1024]; | + | 32│ } |
| - | | + | 33│ |
| - | | + | 34│ } |
| - | | + | 35│ |
| - | | + | 36│ void *threadFunc(void* numRaw) { |
| - | + | 37│ | |
| - | while (1) { | + | 38│ |
| - | char line[1024], nl; | + | |
| - | | + | 48│ while (1) { |
| - | + | 49│ | |
| - | int argOne = atoi(line); | + | 50│ |
| - | if (argOne >= 5 || argOne < 0) | + | 51│ char line[1024]; |
| - | | + | 52│ fgets(line, 1024, win.in); |
| - | + | 53│ | |
| - | | + | 54│ |
| - | + | 55│ int argOne = atoi(line); | |
| - | if (!argTwoTxt) { | + | … |
| - | pthread_mutex_lock(& | + | 61│ char *argTwoTxt = strchr(line, |
| - | | + | 62│ |
| - | pthread_mutex_unlock(& | + | 63│ if (!argTwoTxt) { |
| - | continue; | + | 65│ pthread_mutex_lock(& |
| - | } | + | 66│ |
| - | + | 67│ pthread_mutex_unlock(& | |
| - | argTwoTxt++; | + | 68│ continue; |
| - | char *e; | + | 69│ } |
| - | int argTwo = strtol(argTwoTxt, | + | 70│ |
| - | + | 71│ argTwoTxt++; | |
| - | if (!*e && argTwo < 5 && argTwo >= 0 && argOne != argTwo) { | + | 72│ char *e; |
| - | pthread_mutex_lock(& | + | 73│ int argTwo = strtol(argTwoTxt, |
| - | pthread_mutex_lock(& | + | 74│ |
| - | | + | 75│ if (!*e && argTwo < 5 && argTwo >= 0 && argOne != argTwo) { |
| - | memcpy(item[argOne].text, | + | 77│ pthread_mutex_lock(& |
| - | pthread_mutex_unlock(& | + | 78│ pthread_mutex_lock(& |
| - | pthread_mutex_unlock(& | + | 79│ |
| - | } else { | + | 80│ memcpy(item[argOne].text, |
| - | pthread_mutex_lock(& | + | 81│ pthread_mutex_unlock(& |
| - | | + | 82│ pthread_mutex_unlock(& |
| - | memset(item[argOne].text, | + | 83│ } else { |
| - | strncpy(item[argOne].text, | + | 85│ pthread_mutex_lock(& |
| - | pthread_mutex_unlock(& | + | 86│ |
| - | } | + | 87│ memset(item[argOne].text, |
| - | } | + | 88│ strncpy(item[argOne].text, |
| - | } | + | 89│ pthread_mutex_unlock(& |
| - | + | 90│ } | |
| - | int main(int argc, char **argv) { | + | 91│ } |
| - | | + | 92│ } |
| - | + | | |
| - | printf(" | + | |
| - | " | + | |
| - | " | + | |
| - | " | + | |
| - | " | + | |
| - | " | + | |
| - | | + | |
| - | + | ||
| - | for (int i = 0; i < 5; ++i) | + | |
| - | pthread_mutex_init(& | + | |
| - | + | ||
| - | for (intptr_t i = 1; i < 5; ++i) { | + | |
| - | pthread_t tid; | + | |
| - | pthread_create(& | + | |
| - | pthread_detach(tid); | + | |
| - | } | + | |
| - | threadFunc(0); | + | |
| - | } | + | |
| </ | </ | ||
| - | </ | ||
| < | < | ||
| Line 896: | Line 877: | ||
| When one thread needs to execute some logic once a specific condition is fulfilled, | When one thread needs to execute some logic once a specific condition is fulfilled, | ||
| it should: | it should: | ||
| + | < | ||
| + | <WRAP group> | ||
| + | <WRAP half column> | ||
| - lock a mutex, | - lock a mutex, | ||
| - check the condition, | - check the condition, | ||
| - | - if the condition is false: | + | - while the condition is false: |
| - wait on a condition variable, | - wait on a condition variable, | ||
| - go back to step 2, | - go back to step 2, | ||
| - do the logic, | - do the logic, | ||
| - unlock the mutex. | - unlock the mutex. | ||
| + | </ | ||
| + | <WRAP half column> | ||
| + | < | ||
| + | <pre class=" | ||
| + | <span style=" | ||
| + | <span class=" | ||
| + | <span style=" | ||
| + | < | ||
| + | <span style=" | ||
| + | </ | ||
| + | </ | ||
| + | </ | ||
| + | </ | ||
| A thread that may change the state and thus affect the condition should: | A thread that may change the state and thus affect the condition should: | ||
| + | < | ||
| + | <WRAP group> | ||
| + | <WRAP half column> | ||
| - lock the mutex, | - lock the mutex, | ||
| - do its logic, | - do its logic, | ||
| - signal the condition variable, | - signal the condition variable, | ||
| - unlock the mutex((One can also signal the condition variable after unlocking the mutex.)). | - unlock the mutex((One can also signal the condition variable after unlocking the mutex.)). | ||
| + | </ | ||
| + | <WRAP half column> | ||
| + | < | ||
| + | <pre class=" | ||
| + | <span style=" | ||
| + | < | ||
| + | <span style=" | ||
| + | <span style=" | ||
| + | </ | ||
| + | </ | ||
| + | </ | ||
| + | </ | ||
| < | < | ||
| The example conditions include: | The example conditions include: | ||
| + | < | ||
| * a boolean flag is set; the flag indicates that another thread finished a part of the computation and the results can used, | * a boolean flag is set; the flag indicates that another thread finished a part of the computation and the results can used, | ||
| * a list of items is not empty; the list contains tasks to be done by this thread, | * a list of items is not empty; the list contains tasks to be done by this thread, | ||
os_cp/threads.1744833444.txt.gz · Last modified: (external edit)