小编TSM*_*TSM的帖子

multiprocessing.Pool产生的进程多于仅在Google Cloud上请求的进程

我正在使用Python的multiprocessing.Pool类在进程之间分配任务.

简单的案例按预期工作:

from multiprocessing import Pool

def evaluate:
    do_something()

pool = Pool(processes=N)
for task in tasks:
    pool.apply_async(evaluate, (data,))
Run Code Online (Sandbox Code Playgroud)

产生了N个进程,它们不断地完成我传递给apply_async的任务.现在,我有另一种情况,我有许多不同的非常复杂的对象,每个对象都需要进行计算量大的活动.我最初让每个对象根据需要创建自己的multiprocessing.Pool 在它完成工作的时间,但我最终还是遇到了OSERROR具有开放的文件太多,即使我会假设池会得到使用后垃圾回收.

无论如何,我认为最好为这些复杂对象中的每一个共享同一个池进行计算:

from multiprocessing import Pool

def evaluate:
    do_something()

pool = Pool(processes=N)

class ComplexClass:

    def work:
        for task in tasks:
            self.pool.apply_async(evaluate, (data,))

objects = [ComplexClass() for i in range(50)]

for complex in objects:
    complex.pool = pool


while True:
    for complex in objects:
        complex.work()
Run Code Online (Sandbox Code Playgroud)

现在,当我在我的一台计算机上运行它(OS X,Python = 3.4)时,它就像预期的那样工作.产生了N个进程,每个复杂对象在每个进程中分配它们的任务.但是,当我在另一台计算机上运行它(运行Ubuntu的Google Cloud实例,Python = 3.5)时,会产生大量进程(>> N),整个程序因争用而停止运行.

如果我查看池以获取更多信息:

import random
random_object = random.sample(objects, 1)
print (random_object.pool.processes) …
Run Code Online (Sandbox Code Playgroud)

python multiprocessing google-cloud-platform

9
推荐指数
1
解决办法
938
查看次数

Dynamic selection of method based on runtime parameter type

I've seen similar questions/answers for this posted in the past, but mine differs slightly from the others that I've seen.

Essentially, I have a common interface and several classes that implement/inherit from it. Then, in a separate class, I have methods that must act upon objects given by the interface IObject. However, each of them must be acted upon in different ways, hence why there is a separate declaration of the method for each concrete type that extends IObject.

class …
Run Code Online (Sandbox Code Playgroud)

c#

7
推荐指数
1
解决办法
3455
查看次数

调用void*指针指向的函数

我有一个看起来像这样的事件结构

typedef struct {
    void* fn;
    void* param;
} event;
Run Code Online (Sandbox Code Playgroud)

如何通过指针作为结构的一部分来调用此函数.例如,这些不起作用:

event->(*function)();
event->function();
(*event->function)();
Run Code Online (Sandbox Code Playgroud)

我想知道如何使用和不使用额外的void*param进行函数调用.我最初使用此链接作为参考:

http://www.cprogramming.com/tutorial/function-pointers.html

我之前使用过这些函数指针,但是无法正确获取语法.

c pointers

4
推荐指数
1
解决办法
8039
查看次数

获取WPF Treeview的SelectedItem

我正在使用MVVM Light创建一个WPF应用程序,我有以下TreeView:

<TreeView x:Name="TreeView" 
                  Grid.Column="2" 
                  HorizontalAlignment="Left" Height="463.481" VerticalAlignment="Top" Width="263" 
                  ItemsSource="{Binding PackageView}" Margin="0,5.657,0,0" Grid.Row="1" Grid.RowSpan="2" Grid.ColumnSpan="2">
            <i:Interaction.Triggers>
                <i:EventTrigger EventName="SelectedItemChanged">
                    <i:InvokeCommandAction Command="{Binding Command}" 
                    CommandParameter="SelectedItemChanged"/>
                </i:EventTrigger>
            </i:Interaction.Triggers>
            <TreeView.ItemContainerStyle>
                <Style TargetType="{x:Type TreeViewItem}">
                    <Setter Property="IsExpanded" Value="{Binding IsExpanded, Mode=TwoWay}" />
                    <Setter Property="IsSelected" Value="{Binding IsSelected, Mode=TwoWay}" />
                    <Setter Property="FontWeight" Value="Normal" />
                    <Style.Triggers>
                        <Trigger Property="IsSelected" Value="True">
                            <Setter Property="FontWeight" Value="Bold" />
                        </Trigger>
                    </Style.Triggers>
                </Style>
            </TreeView.ItemContainerStyle>
Run Code Online (Sandbox Code Playgroud)

当选择被更改时,我想将新选择的项目作为参数发送到命令.有没有办法做到这一点?我的印象是你可以使用EventToCommand做到这一点,但是当我尝试使用它们时,它表示版本4中不再支持它们,我找不到合适的解决方法.

谢谢.

c# wpf mvvm mvvm-light

3
推荐指数
1
解决办法
5703
查看次数

基于枚举的静态数组:C头

我在C头文件中有一个枚举值.我想定义一个额外的数组或一组值,其中每个值对应一个枚举值.本质上,该数组将是与每个枚举值相关的一些信息的查找表.但是,我想在编译时在头文件中执行此操作.

有什么好办法来实现这个目标?

下面是如何使用两个单独的枚举或定义结构来完成它的示例.有没有更优雅的方法来完成这个只使用op枚举?

enum op {
op1,
op2,
op3
};

enum op_information {
op1_info = 0xff,
op2_info = 0xf3,
op3_info = 0xc1
}
Run Code Online (Sandbox Code Playgroud)

更新:如果有任何方法使用引用静态定义数组,对我来说同样有价值的帮助会回答.也就是说,而不是做:

ushort op_information = { 0xff, 0xf3, 0xc1 },
Run Code Online (Sandbox Code Playgroud)

我们能完成吗?

ushort op_information[3]
op_information[op.op1] = 0xff;
op_information[op.op2] = 0xf3;
op_information[op.op3] = 0xc1
Run Code Online (Sandbox Code Playgroud)

在编译时?

c

3
推荐指数
1
解决办法
254
查看次数

非阻塞线程

我正在重构一个由多个全尺寸应用程序使用的 C# 项目。此类与硬件交互,通常需要数百毫秒或更长时间来执行某些命令。在许多情况下,我用 ThreadPool 调用替换以前程序员编写的 Thread.Wait() 调用来执行这些操作。

现在,该项目向使用它的多个项目提供的某些功能需要数百毫秒或更长时间才能执行并向调用程序返回该程序必须使用的值。我的问题是,我是否可以在该项目中使用某种机制来使这些调用在主线程以外的某个线程上执行并返回?换句话说,从这个项目的角度来看,我想让这些方法成为非阻塞的,而不是要求使用这些函数的其他应用程序在单独的线程中进行调用。

谢谢

c# multithreading

1
推荐指数
1
解决办法
2780
查看次数