P*A 发帖数: 189 | 1 写个函数把一个数组通过一个函数map到另一个数组
例子,
f(n) { return ++n; }
m([1,2], f) => [2,3]
要求可以多线程并行处理多个数组元素。 |
j****y 发帖数: 550 | 2 Bless
【在 P*A 的大作中提到】![](/moin_static193/solenoid/img/up.png) : 写个函数把一个数组通过一个函数map到另一个数组 : 例子, : f(n) { return ++n; } : m([1,2], f) => [2,3] : 要求可以多线程并行处理多个数组元素。
|
l*********u 发帖数: 19053 | 3 bless
【在 P*A 的大作中提到】![](/moin_static193/solenoid/img/up.png) : 写个函数把一个数组通过一个函数map到另一个数组 : 例子, : f(n) { return ++n; } : m([1,2], f) => [2,3] : 要求可以多线程并行处理多个数组元素。
|
G******e 发帖数: 229 | |
d******a 发帖数: 238 | |
d******a 发帖数: 238 | |
f**l 发帖数: 359 | |
s***0 发帖数: 117 | 8 Functors.
If you said function pointers, I'd be interested in knowing how to make that
thread safe. |
k***g 发帖数: 58 | 9 如果单纯的只是每个元素加一,不同thread处理不同区域的元素,应该不存在thread
safe issue吧?
这题考点是什么?LZ咋答的? |
P*A 发帖数: 189 | 10 我开始先写了个最基本的循环的版本,
面试官说现在要求在多核的机器上并行处理数组元素,
然后我写了每个元素一个线程的,
面试官说数组很大的话,会有太多线程
然后我就跟他说了可以把数组根据cpu的书目分段,每段一个线程,
面试官说这样弄,不同线程需要的时间不同,效率就不高了。
然后就没时间了,不过我也没辙了。
我对多线程也不熟,被考到这题也比较郁闷;不过我问他用多线程的时候,他说你觉得
有必要就用,是不是可以不用?
还是等大牛来给个标准的解答。
【在 k***g 的大作中提到】![](/moin_static193/solenoid/img/up.png) : 如果单纯的只是每个元素加一,不同thread处理不同区域的元素,应该不存在thread : safe issue吧? : 这题考点是什么?LZ咋答的?
|
|
|
w****x 发帖数: 2483 | |
p**p 发帖数: 2493 | |
n**s 发帖数: 426 | 13 Bless
【在 P*A 的大作中提到】![](/moin_static193/solenoid/img/up.png) : 写个函数把一个数组通过一个函数map到另一个数组 : 例子, : f(n) { return ++n; } : m([1,2], f) => [2,3] : 要求可以多线程并行处理多个数组元素。
|
d******a 发帖数: 238 | 14 搞个全局的index,用个锁保护index就可以了. 可以当成一个只有消费者的生产者-消
费者模型来看。
int index = 0;
void m(int *a, int n, void (*f)(int * ))
{
lock(mutex);
index++;
unlock(mutex);
if (index < n)
f( &a[index]);
}
void f(int *p)
{
*p = *p + 1;
} |
j********e 发帖数: 1192 | 15 可以把数据分成n段(n >> cpu数),然后搞个n bit的bitmap,
然后每个线程通过mutex从bitmap里找一个0,然后把它改成1,
然后去处理这个bit对应的那段数据。这样即使每个线程处理
速度不同,也没有太大关系。线程数量就跟CPU数量相同。
【在 P*A 的大作中提到】![](/moin_static193/solenoid/img/up.png) : 我开始先写了个最基本的循环的版本, : 面试官说现在要求在多核的机器上并行处理数组元素, : 然后我写了每个元素一个线程的, : 面试官说数组很大的话,会有太多线程 : 然后我就跟他说了可以把数组根据cpu的书目分段,每段一个线程, : 面试官说这样弄,不同线程需要的时间不同,效率就不高了。 : 然后就没时间了,不过我也没辙了。 : 我对多线程也不熟,被考到这题也比较郁闷;不过我问他用多线程的时候,他说你觉得 : 有必要就用,是不是可以不用? : 还是等大牛来给个标准的解答。
|
c*******r 发帖数: 610 | |
s******n 发帖数: 3946 | |
R*****a 发帖数: 48 | |
n*2 发帖数: 19062 | |
P*A 发帖数: 189 | 20 写个函数把一个数组通过一个函数map到另一个数组
例子,
f(n) { return ++n; }
m([1,2], f) => [2,3]
要求可以多线程并行处理多个数组元素。 |
|
|
j****y 发帖数: 550 | 21 Bless
【在 P*A 的大作中提到】![](/moin_static193/solenoid/img/up.png) : 写个函数把一个数组通过一个函数map到另一个数组 : 例子, : f(n) { return ++n; } : m([1,2], f) => [2,3] : 要求可以多线程并行处理多个数组元素。
|
l*********u 发帖数: 19053 | 22 bless
【在 P*A 的大作中提到】![](/moin_static193/solenoid/img/up.png) : 写个函数把一个数组通过一个函数map到另一个数组 : 例子, : f(n) { return ++n; } : m([1,2], f) => [2,3] : 要求可以多线程并行处理多个数组元素。
|
G******e 发帖数: 229 | |
d******a 发帖数: 238 | |
d******a 发帖数: 238 | |
f**l 发帖数: 359 | |
s***0 发帖数: 117 | 27 Functors.
If you said function pointers, I'd be interested in knowing how to make that
thread safe. |
k***g 发帖数: 58 | 28 如果单纯的只是每个元素加一,不同thread处理不同区域的元素,应该不存在thread
safe issue吧?
这题考点是什么?LZ咋答的? |
P*A 发帖数: 189 | 29 我开始先写了个最基本的循环的版本,
面试官说现在要求在多核的机器上并行处理数组元素,
然后我写了每个元素一个线程的,
面试官说数组很大的话,会有太多线程
然后我就跟他说了可以把数组根据cpu的书目分段,每段一个线程,
面试官说这样弄,不同线程需要的时间不同,效率就不高了。
然后就没时间了,不过我也没辙了。
我对多线程也不熟,被考到这题也比较郁闷;不过我问他用多线程的时候,他说你觉得
有必要就用,是不是可以不用?
还是等大牛来给个标准的解答。
【在 k***g 的大作中提到】![](/moin_static193/solenoid/img/up.png) : 如果单纯的只是每个元素加一,不同thread处理不同区域的元素,应该不存在thread : safe issue吧? : 这题考点是什么?LZ咋答的?
|
w****x 发帖数: 2483 | |
|
|
p**p 发帖数: 2493 | |
n**s 发帖数: 426 | 32 Bless
【在 P*A 的大作中提到】![](/moin_static193/solenoid/img/up.png) : 写个函数把一个数组通过一个函数map到另一个数组 : 例子, : f(n) { return ++n; } : m([1,2], f) => [2,3] : 要求可以多线程并行处理多个数组元素。
|
d******a 发帖数: 238 | 33 搞个全局的index,用个锁保护index就可以了. 可以当成一个只有消费者的生产者-消
费者模型来看。
int index = 0;
void m(int *a, int n, void (*f)(int * ))
{
lock(mutex);
index++;
unlock(mutex);
if (index < n)
f( &a[index]);
}
void f(int *p)
{
*p = *p + 1;
} |
j********e 发帖数: 1192 | 34 可以把数据分成n段(n >> cpu数),然后搞个n bit的bitmap,
然后每个线程通过mutex从bitmap里找一个0,然后把它改成1,
然后去处理这个bit对应的那段数据。这样即使每个线程处理
速度不同,也没有太大关系。线程数量就跟CPU数量相同。
【在 P*A 的大作中提到】![](/moin_static193/solenoid/img/up.png) : 我开始先写了个最基本的循环的版本, : 面试官说现在要求在多核的机器上并行处理数组元素, : 然后我写了每个元素一个线程的, : 面试官说数组很大的话,会有太多线程 : 然后我就跟他说了可以把数组根据cpu的书目分段,每段一个线程, : 面试官说这样弄,不同线程需要的时间不同,效率就不高了。 : 然后就没时间了,不过我也没辙了。 : 我对多线程也不熟,被考到这题也比较郁闷;不过我问他用多线程的时候,他说你觉得 : 有必要就用,是不是可以不用? : 还是等大牛来给个标准的解答。
|
c*******r 发帖数: 610 | |
s******n 发帖数: 3946 | |
R*****a 发帖数: 48 | |
n*2 发帖数: 19062 | |
f*********m 发帖数: 726 | 39 能详细说说吗?
谢谢。
that
【在 s***0 的大作中提到】![](/moin_static193/solenoid/img/up.png) : Functors. : If you said function pointers, I'd be interested in knowing how to make that : thread safe.
|
r****m 发帖数: 70 | 40 package test;
public class MapTest implements Runnable{
int[] a;
int index = 0;
MapTest(int[] a) {
this.a = a;
}
int fun(int i) {
return i+1;
}
@Override
public void run() {
int i;
while((i = getIndex()) < a.length) {
System.out.println(Thread.currentThread().getName() + " " + i);
a[i] = fun(a[i]);
}
}
synchronized int getIndex() {
return (index++);
}
static int MAX_NUM_THREADS = 10;
public static void main(String[] args) throws InterruptedException {
int size = 1000000;
int[] a = new int[size];
for (int i=0; i
a[i] = i;
}
MapTest m = new MapTest(a);
for (int i = 0; i < MAX_NUM_THREADS; i++) {
Thread t = new Thread(m);
t.start();
}
}
} |
|
|
m******s 发帖数: 1469 | 41 Bless
【在 P*A 的大作中提到】![](/moin_static193/solenoid/img/up.png) : 写个函数把一个数组通过一个函数map到另一个数组 : 例子, : f(n) { return ++n; } : m([1,2], f) => [2,3] : 要求可以多线程并行处理多个数组元素。
|
p**p 发帖数: 2493 | |