我有一些由开发人员编写的python代码.它将UDP消息发送到P2P网络中的节点.我正在编写该代码的并行版本.该代码将多个并行消息发送到P2P网络.不幸的是,代码消耗了太多的CPU.我假设这是因为所有的网络I/O轮询.如果我使用异步I/O(扭曲框架),这是一个好主意吗？
我有一个数组,我希望调查,只有当数组==另一个变量打印出来的东西,但它似乎打印出语句无论如何,我错过了一些愚蠢的东西？
var candArray =
['Green...', 'Brown...', 'Black...', 'White...', 'Grey....','Blue....', 'Pink....'];
var votesArray= [33,51,43,22,61,51,47];
var maximumVote = 61;
for(i=0; i<candArray .length; i++){
if(votesArray[i] == maximumVote);{
document.write(candArray [i] + ' is hearby declared elected');}
}
所有帮助赞赏.谢谢
编辑:OMG我知道这很简单,但是我已经这样做了2个小时,刚进入那个阶段你不会检查简单的东西因为你太累了.非常感谢大家
我目前正在使用以下代码来运行进程并从我自己的程序中打印其输出.我的问题是我想做的不仅仅是打印输出.但是,由于正在执行的进程几乎不会将输出打印到控制台,因此几乎从不执行注释行,因为readLine()方法是阻塞的.
Process p = Runtime.getRuntime().exec(executablePath);
ProcessWatcher pw = new ProcessWatcher(p);
BufferedReader output = new BufferedReader(new InputStreamReader(p.getInputStream()));
while(!pw.isFinished()) {
String line = output.readLine();
if(line != null) {
System.out.println(line);
}
// I want to do something in parallel here
}
如果我可以给readLine()调用某种超时,或者如果我可以在自己的Thread中运行它,我的问题就会解决.后者是首选,但前者是可以接受的.我的主要目的是保持代码简单.
是否有一种很好的,简单的方法来并行化阻塞调用,或者我是否需要创建一个为此实现Runnable的新类？
我在带有两个双核处理器的linux os服务器上运行我的应用程序.
问题是,在"top"linux命令中,第二个处理器的加载速度不超过10%,而第一个处理器在某些脚本上停留在100%,持续3-4秒.
我怎样才能使用我服务器的那两个CPU的电源？
前一个问题询问如何有效地找到CUDA中数组的最大值:在CUDA中查找最大值,最高响应提供了一个关于优化还原内核的NVIDIA演示文稿的链接.
如果您使用的是Visual Studio,只需删除标题引用,以及CPU EXECUTION之间的所有内容.
我设置了一个找到max的变体,但它与CPU发现的不匹配:
// Returns the maximum value of
// an array of size n
float GetMax(float *maxes, int n)
{
int i = 0;
float max = -100000;
for(i = 0; i < n; i++)
{
if(maxes[i] > max)
max = maxes[i];
}
return max;
}
// Too obvious...
__device__ float MaxOf2(float a, float b)
{
if(a > b) return a;
else return b;
}
__global__ void MaxReduction(int n, float *g_idata, float *g_odata) …抱歉标题不好.我无法想出更好的东西.
我见过的每个CUDA程序示例都有预定义的数据,可以并行化.一个常见的例子是两个矩阵的总和,其中两个矩阵已经被填充.但是那些产生新任务的程序又如何呢？我如何在CUDA中建模？如何传递结果,以便其他线程可以开始处理它.
例如:假设我在一个作业上运行内核.这项工作产生了10个新的独立工作.他们每个人都会产生10个新的独立工作,依此类推.这似乎是一项高度并行的任务,因为每项工作都是独立的.问题是我不知道如何在CUDA中对此进行建模.我已经尝试在CUDA中进行它,我在内核中使用了一个while循环来保持轮询,如果一个线程可以开始计算.每个线程都分配了一个作业.但那没用.它似乎忽略了while循环.
代码示例:
On host:
fill ready array with 0
ready[0] = 1;
On device:
__global__ void kernel(int *ready, int *result)
{
int tid = threadIdx.x;
if(tid < N)
{
int condition = ready[tid];
while(condition != 1)
{
condition = ready[tid];
}
result[tid] = 3;// later do real computation
//children jobs is now ready to work
int childIndex = tid * 10;
if(childIndex < (N-10))
{
ready[childIndex + 1] = 1; ready[childIndex + 2] = 1;
ready[childIndex + 3] …我需要让计算的一部分是平行的.它是向量计算,有时我需要对每个值进行一次运算.所以我想让它成为平行的.
我无法解释我在例子上的计算(它唯一的简单示例,而不是我的算法):我正在向前移动指针,当我找到数字5时,我向向量中的每个数字添加5.
所以我想避免在主机上执行此操作,并在每个指针移动后将所有大向量复制到设备<=>主机(可重复).我认为它可能比在Host上的所有内容效率低.
所以我知道我将所有向量复制到Device一次然后我将启动算法.
这是一个简单的应对方案,展示了我的问题:
__device__ void devFunction(long long unsigned int *arr, long long unsigned int param, long long unsigned int N) {
long long unsigned int i = blockIdx.x* blockDim.x+ threadIdx.x;
// do something ...
}
__global__ void globFunction(long long unsigned int *arr, long long unsigned int N) {
do {
devFunction(arr, param, N); // I want to run many threads here like <<<...>>>
// do something ...
} while(/* ... */);
}
int main() {
// declare array, …我通过使用cURL(GET)来查询API,并且API每次调用只给出了25个结果(这是一个硬限制,我无能为力,因为它不是我的).
结果如下:
<response v="2">
<query>my nifty query</query>
<location>new york, ny</location>
<totalresults>920</totalresults>
<start>1</start>
<end>25</end>
<pageNumber>0</pageNumber>
<results>
<result></result>
<result></result>
...
</results>
</response>
总结果(出现在返回的xml [上面]中)最多可以包含1,000个结果,并且在大多数情况下,我通常每个查询有1,000个结果,所以我基本上必须调用API 40次(即25个结果 -每次通话×40次通话= 1,000次结果).每次调用,我都会更改API 启动参数并将其增加25(即0,25,50,...,975).
整个过程大约需要8秒钟才能完成,因为我目前以同步方式调用API(我curl_exec()用来执行GET命令,在for循环中逐个执行).是否有任何有效且更快速的方式以并行方式调用API并更快地获得这些结果？谢谢.
var LevelCode:Array = [10,20,30,40,50,60,70,80,...,990,1000];
var Piece0:Timer = new Timer(50, LevelCode[0]);
var Piece1:Timer = new Timer(50, LevelCode[1]);
...
var Piece98:Timer = new Timer(50, LevelCode[98]);
var Piece99:Timer = new Timer(50, LevelCode[99]);
我想同时启动Piece0计时器,Piece1计时器等.我试过了Piece0+Piece1.start();,但没办法.
你们能帮助我吗？
我需要在多个正在运行的线程中快速生成随机浮点数.我尝试过使用System.Random,但它对我的需求来说太慢了,它在多个线程中返回相同的数字.(当我在一个线程中运行我的应用程序时,它工作正常.)另外,我需要确保生成的数字在0到100之间.
这是我现在正在尝试的内容:
number = random.NextDouble() * 100;
我该怎么办呢？