diff --git a/communication_techniques/src/main.c b/communication_techniques/src/main.c index fa34f72..1cdada4 100644 --- a/communication_techniques/src/main.c +++ b/communication_techniques/src/main.c @@ -166,6 +166,20 @@ void *producer(void *cont_ptr_void) return NULL; } } + else + { + pthread_t tid; + cpu_set_t cpuset; + + tid = pthread_self(); + CPU_ZERO(&cpuset); + CPU_SET(2, &cpuset); + if (pthread_setaffinity_np(tid, sizeof(cpu_set_t), &cpuset)) + { + perror("pthread_setaffinity_np"); + return NULL; + } + } printf("Registering: %p !\n", (void*) pthread_self()); add_sender(); k = cont_ptr_void; @@ -207,7 +221,7 @@ void *receptor(void *a) tid = pthread_self(); CPU_ZERO(&cpuset); - CPU_SET(1, &cpuset); + CPU_SET(0, &cpuset); if (pthread_setaffinity_np(tid, sizeof(cpu_set_t), &cpuset)) { perror("pthread_setaffinity_np");