2015-12-10 37 views
0

这是我的代码:子线程将错误的数据返回到主线程?

pthread_t client_thread1, client_thread2; 
int *child_thread_data = new int; 

pthread_mutex_t testlock; 

typedef struct 
{ 
    int thread_no; 
    char thread_name[100]; 
} thrdata; 

int main() 
{ 
    void *ret_data1 = new 
    int[10]; 
    void *ret_data2 = new 
    int[10]; 

    thrdata thr1; 
    thrdata thr2; 

    thr1.thread_no = 10; 
    strcpy((thr1.thread_name), "thread one"); 
    thr2.thread_no = 20; 
    strcpy((thr2.thread_name), "thread two"); 

    pthread_create(&client_thread1, &attr, &client_handler, &thr1); 
    pthread_create(&client_thread2, &attr, &client_handler, &thr2); 

    cout << "value of ret_data1 before thread 1 join " << *(int *) ret_data1 
     << endl; 
    cout << "value of ret_data2 before thread 2 join " << *(int *) ret_data2 
     << endl; 

    pthread_join(client_thread1, &ret_data1); 
    cout << "value returned by thread1 is " << *(int *) ret_data1 << endl; 

    pthread_join(client_thread2, &ret_data2); 
    cout << "value returned by thread2 is " << *(int *) ret_data2 << endl; 

    return 0; 
} 

void *client_handler(void *arg) 
{ 
    pthread_mutex_lock(&testlock); 

    thrdata *client_thd; 
    client_thd = (thrdata *) arg; 

    cout << "inside client_handler value of private data no is \n" 
     << client_thd->thread_no << endl; 
    cout << "inside client_handler value of private data name is \n" 
     << client_thd->thread_name << endl; 

    if (pthread_equal(client_thread1, pthread_self())) 
    { 
    *child_thread_data = 100; 
    pthread_mutex_unlock(&testlock); 
    pthread_exit((void *) &child_thread_data); 
    } 

    else if (pthread_equal(client_thread2, pthread_self())) 
    { 
    *child_thread_data = 200; 
    pthread_mutex_unlock(&testlock); 
    pthread_exit((void *) &child_thread_data); 
    } 
} 

输出:

value of ret_data1 before thread 1 join 0 
value of ret_data2 before thread 2 join 0 


inside client_handler value of private data no is 20 
inside client_handler value of private data name is thread two 


calling pthread_exit of thread2 and value of child_thread_data is 200 


inside client_handler value of private data no is 10 
inside client_handler value of private data name is thread one 

calling pthread_exit of thread1 and value of child_thread_data is 100 

value returned by thread1 is 28262416 
value returned by thread2 is 28262416 

为什么两个子线程返回相同的数据?我在pthread_exit(28262416)中设置了不同的数据,但我仍然在两种情况下都收到相同的数据。请让我知道原因。

谢谢。

+1

C中支持“new”吗? –

回答

2

我看到两个问题:首先这两个线程都修改并返回相同的指针。其次,线程将指针返回给指针(例如int **)。

第一个问题只会给你相同的结果(但与你现在得到的结果无关)。第二个问题是什么给你你现在得到的结果(这是变量child_thread_data在内存中的地址)。

要解决这两个问题,首先需要两个值来分配和返回,并返回一个指针(int *)。

噢,锁并不重要,因为最后运行的线程总是会覆盖结果。

你也有内存泄漏,你分配内存并分配给ret_data1ret_data2然后你只需丢弃该内存时pthread_join覆盖这些指针。

我的建议是你回去几步,find a good book about C并从指针章节重新开始。并尝试了解何时何地应该使用指针。因为现在你在不需要的时候使用指针(例如,不需要child_thread_data作为指针)。

+0

如果首先执行线程1,并且先调用pthread_join,然后执行thread2,则在这种情况下,printf将有两个不同的值... –

+0

@JeegarPatel是的,但这是一个非常大的“if”。而且不太可能,因为控制台输出很慢,变量'child_thread_data'在打印之前可能有时间被第二个线程修改。 –

+0

对......你的回答在所有情况下都是正确的。 +1 –