- android - 多次调用 OnPrimaryClipChangedListener
- android - 无法更新 RecyclerView 中的 TextView 字段
- android.database.CursorIndexOutOfBoundsException : Index 0 requested, 光标大小为 0
- android - 使用 AppCompat 时,我们是否需要明确指定其 UI 组件(Spinner、EditText)颜色
我尝试用 C 编写多线程示例。这是从用户获取的数字和两个线程中的总和数字。
线程彼此直接远离,从前到后和从后到前。
我正在使用信号量来管理全局变量,但输出显示信号量无法正常工作。
怎么了?
代码输出:
Array size? :10
Array of contents? :4 2 8 1 5 3 7 9 6 10
Thread_1 > read 4, sum is = 4
Thread_1 > read 2, sum is = 6
Thread_1 > read 8, sum is = 14
Thread_1 > read 1, sum is = 15
Thread_1 > read 5, sum is = 20
Thread_1 > read 3, sum is = 23
Thread_1 > read 7, sum is = 30
Thread_1 > read 9, sum is = 39
Thread_1 > read 6, sum is = 45
Thread_1 > read 10, sum is = 55
Thread_1 > End.
Thread_2 > End.
代码:
#include <stdio.h>
#include <pthread.h>
#include <stdlib.h>
#include <semaphore.h>
int *array; //Global integer array
int sum; //Global sum variable
int counter = 0;
sem_t mutex;
void *front_to_back( void *val )
{
int SIZE;
SIZE = *((int *) val);
while (1)
{
sem_wait(&mutex);
if( counter != SIZE )
{
sum = sum + array[counter];
printf("Thread_1 > read %d, sum is = %d \n", array[counter], sum);
counter++;
}else
{
printf("Thread_1 > End. \n");
sem_post(&mutex);
break;
}
sem_post(&mutex);
}
}
void *back_to_front( void *val )
{
int SIZE;
SIZE = *((int *) val);
int i=1;
while (1)
{
sem_wait(&mutex);
if( counter != SIZE )
{
sum = sum + array[SIZE - i];
printf("Thread_2 > read %d, sum is = %d \n", array[SIZE - i], sum);
counter++;
i++;
}else
{
printf("Thread_2 > End. \n");
sem_post(&mutex);
break;
}
sem_post(&mutex);
}
}
main(){
int SIZE;
printf("Array size? :");
scanf("%d", &SIZE);
array = malloc(SIZE*sizeof(int));
int i=0;
printf("Array of contents? :");
for (i ; i<SIZE ; i++)
{
scanf("%d", &array[i]);
}
pthread_t t[2];
sem_init(&mutex, 0, 1);
pthread_create(&t[1], NULL, front_to_back, (void *) &SIZE );
pthread_create(&t[2], NULL, back_to_front, (void *) &SIZE );
pthread_join(t[1],NULL);
pthread_join(t[2],NULL);
free(array);
sem_destroy(&mutex);
}
最佳答案
您应该在 main()
中使用 t[0]
和 t[1]
:大小为 N 的数组
在 0..N-1
中有有效的索引,所以,首先,修复它。这是正确的代码:
pthread_create(&t[0], NULL, front_to_back, (void *) &SIZE );
pthread_create(&t[1], NULL, back_to_front, (void *) &SIZE );
pthread_join(t[0],NULL);
pthread_join(t[1],NULL);
理想情况下,您还应该检查 malloc()
和 pthread_create()
是否成功。这些函数可能会返回错误,您应该处理它。您的代码忽略了这些错误(对于越界访问,您实际上很幸运它能正常工作)。
此外,为什么您将信号量当作互斥量来使用?这里并不真正需要信号量——当您不需要信号量的强大功能和灵 active 时,只需使用互斥量即可。一个重要的区别是信号量允许您在一个线程上等待并在另一个线程上发送消息,而互斥量必须由获取它的线程解锁。
因此,在互斥锁就足够的情况下使用信号量可能会掩盖代码中的错误。所以,我会继续使用互斥锁。这是包含所有更改的代码:
#include <stdio.h>
#include <pthread.h>
#include <stdlib.h>
int *array; //Global integer array
int sum; //Global sum variable
int counter = 0;
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
void *front_to_back( void *val )
{
int SIZE;
SIZE = *((int *) val);
while (1)
{
pthread_mutex_lock(&mutex);
if( counter != SIZE )
{
sum = sum + array[counter];
printf("Thread_1 > read %d, sum is = %d \n", array[counter], sum);
counter++;
}else
{
printf("Thread_1 > End. \n");
pthread_mutex_unlock(&mutex);
break;
}
pthread_mutex_unlock(&mutex);
}
return NULL;
}
void *back_to_front( void *val )
{
int SIZE;
SIZE = *((int *) val);
int i=1;
while (1)
{
pthread_mutex_lock(&mutex);
if( counter != SIZE )
{
sum = sum + array[SIZE - i];
printf("Thread_2 > read %d, sum is = %d \n", array[SIZE - i], sum);
counter++;
i++;
}else
{
printf("Thread_2 > End. \n");
pthread_mutex_unlock(&mutex);
break;
}
pthread_mutex_unlock(&mutex);
}
return NULL;
}
int main(void) {
int SIZE;
printf("Array size? :");
scanf("%d", &SIZE);
array = malloc(SIZE*sizeof(int));
int i=0;
printf("Array of contents? :");
for (; i<SIZE ; i++)
{
scanf("%d", &array[i]);
}
pthread_t t[2];
pthread_create(&t[0], NULL, front_to_back, (void *) &SIZE );
pthread_create(&t[1], NULL, back_to_front, (void *) &SIZE );
pthread_join(t[0],NULL);
pthread_join(t[1],NULL);
free(array);
return 0;
}
我第一眼看不出代码有任何其他问题。
现在,您的问题似乎是您没有看到任何并行性。您应该尝试使用更大的阵列。单个线程可能能够在上下文切换之前处理一个 10 元素数组。
更新:我刚刚尝试了包含 3000 个元素的数组的代码。您可以清楚地看到它们并行执行。
关于c - 信号量似乎无法在多线程中正常工作,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/30288373/
谁能帮我解决这个问题?我有一个 Tomcat 和简单的 JSF 应用程序:https://github.com/gooamoko/jsfbilling/ .当我在 Tomcat 上运行应用程序时,它运
我有两个这样的域类,第一个是 Manager : package com.mnm class Manager { String name; static hasMany = [ pro
当我运行以下代码时,打印输出似乎不正确。 void thread_Calc(int *pos) { printf("recieved %d\n", *pos); sig = -1; man
这个问题在这里已经有了答案: How to access a local variable from a different function using pointers? (10 个答案) 关闭
我编写了一个程序,其中列表构建器方法返回 IEnumerable of string,其中包括大量字符串(100 万个项目),我将其存储在 List of string 中,然后它将所有项目附加到 中
我正在尝试编写一个 IRC 类型的聊天客户端,它具有可以连接到服务器的客户端。我试图让它在本地 atm 上工作(使用 FIFOS 而不是套接字)。 我遇到了以下我似乎无法解决的问题: 接受新的客户端连
我的一个 cronjobs 每天发送一封电子邮件 35 6 * * * cd $EZPUBLISHROOT && $PHP runcronjobs.php -q 2>&1 我停止使用 cron sud
我使用 WPF 打印路径来处理在我们的应用程序中创建的大型图表。整个图表由视觉效果组成。 所谓的“DesignerPaginator”对图表进行分页(非常简单)。 从这一点来说,我做了以下三件事: -
我尝试在更新之前跟踪系统应用程序并使用: public static boolean isSystemApplication(Context ctx, IContent content) {
我在这里附上了一个查询分析结果,https://explain.depesz.com/s/x9BN 这是查询 EXPLAIN ANALYZE SELECT branche
我正在做一个 CXF(spring) 项目 (HUB)。部署后,我可以看到肥皂和休息服务列表,我通过两个地址打开它。一种是使用本地主机,第二种是使用我电脑的 ip。所以我得到了这些输出。 使用本地主机
这是一个 AnyHashable 不支持枚举转换的简单案例。 enum testEnum: String { case Test } let myObject: AnyHashable = t
我的主要目标是比较存储在数据库和 XLSX 文件中的数据。 为此,我按以下方式创建了两个列表: private class ProductList { public string produc
我从 CMake 3.6 更新到任何最新版本 (3.12.0-rc2),现在我的一个程序无法编译。 奇怪的是,错误消息显示了标准库本身中的 undefined symbol 。这是错误消息: Unde
我希望将我的自定义对话框动画化为从特定点出现,但我无法为对话框设置动画。 该对话框是一个基本的 RelativeLayout,设置为 extends Dialog 类中的布局。 正如这里的一些答案所建
我已经在这个论坛上调查过很多类似的问题,但似乎没有一个能解决我的问题。 我会在底部列出我在这个论坛上看到的一些问题页面,但让我先谈谈我对这个问题的看法。 我正在使用 codeigniter v 2.x
我正在尝试在 RHEL 7 上启动一个 docker-compose 项目作为 systemd 服务。这是我的 systemd 脚本 (/etc/systemd/system/wp.service):
这个问题已经有答案了: "Notice: Undefined variable", "Notice: Undefined index", "Warning: Undefined array key",
我正在尝试在 RHEL 7 上启动一个 docker-compose 项目作为 systemd 服务。这是我的 systemd 脚本 (/etc/systemd/system/wp.service):
此问题出现在my last question here之后。我想将每个按钮聚焦和失去焦点背景设置为主菜单(ContentPane 即 JPanel)下方的背景颜色,因此按钮看起来像选项卡。它在不同的环
我是一名优秀的程序员,十分优秀!