pthread参数的值已更改
这是我的主要function,其中NO_RECIEVERS = 3
。 我试图使用我发送的i
的值来区分编写器和读取器线程。
int main() { int status, i; pthread_t tr[NO_RECIEVERS], tw[NO_SENDERS], bd; i=1; for(i=1; i<=NO_SENDERS; i++) { pthread_create(&tw[i-1], NULL, writer, &i); } for(i=1; i<=NO_RECIEVERS; i++) { printf("%d\n", i); pthread_create(&tr[i-1], NULL, reader, &i); } pthread_create(&bd, NULL ,daemon_thread, NULL); for(i=1; i<=NO_SENDERS; i++) { pthread_join(tw[i-1], NULL); } for(i=1; i<=NO_RECIEVERS; i++) { pthread_join(tr[i-1], NULL); } pthread_join(bd, NULL); return 0; }
我的读者function如下
void* reader(void *val) { int ret, fd, id; struct mssg data; id = *(int*)val; printf("id: %d %d\n", id, *(int*)val); while(1) {
但是这个函数似乎是创建了一些带有id的随机值的线程..我得到这样的日志
... id: 1 1 ... id: 2 2 ... id: 1 1
下次我得到..它的随机性
... id: 1 1 ... 2 id: 2 2 ... id: 4 4
但我指定的值仅限于1,2,3
你把&i
传递给了你创建的所有线程……所以每个人都有一个指向i
的指针,当他们取消引用它来读取i
的值时,他们读到的就是i
当时碰巧遇到的。
如果你想在pthread_create
时传递i
的值,我建议malloc()
一小块内存,将i
复制到它并将malloced的东西传递给线程(它可以读取它和free()
或任何其他方法,为每个创建的线程在不同的位置提供i
的副本。