plan("multiprocess", workers = 2) Error: Strategy 'multiprocess' is defunct in future (>= 1.32.0) [2023-03-06]. Instead, explicitly specify either 'multisession' (recommended) or 'multicore'.
时间: 2024-02-01 14:04:54 浏览: 167
这是因为在未来的版本中,'multiprocess'策略已经被废弃。您需要明确指定要使用的策略。建议使用'multisession'或'multicore'。如果您想要使用多进程并行,可以将策略更改为'multicore',如果您想要使用多进程会话并行,可以将策略更改为'multisession'。例如,如果您想要使用'multicore'策略,并且使用2个工作进程,则可以使用以下代码:
```python
plan(strategy='multicore', workers=2)
```
相关问题
plan("multiprocess", workers = 6) ###compute cores Error: Strategy 'multiprocess' is defunct in future (>= 1.32.0) [2023-03-06]. Instead, explicitly specify either 'multisession' (recommended) or 'multicore'.
这个错误是因为在 future (>= 1.32.0) 版本中,'multiprocess' 策略已经被废弃了。相反,你需要明确指定 'multisession'(推荐)或 'multicore'。如果你想使用多进程策略,可以将其更改为 'multicore'。例如:
```python
plan("multicore", workers=6)
```
这将使用多个 CPU 核心来并行计算。如果你使用的是 Dask,也可以使用 'dask.distributed' 模块来实现多进程计算。
==3564== Invalid write of size 8 ==3564== at 0x4C2E8BE: memcpy@@GLIBC_2.14 (vg_replace_strmem.c:1033) ==3564== by 0x4F0AA4E: Gopher::Internal::BufferedBlockInStream::read(char*, int) (BufferedBlockInStream.cpp:124) ==3564== by 0x4F0F54E: read (FileInStream.cpp:128) ==3564== by 0x4F0F54E: Gopher::Internal::FileInStream::read(char*, int) (FileInStream.cpp:109) ==3564== by 0x4F0F66B: Gopher::Internal::FileInStream::decryptRead(char*, int) (FileInStream.cpp:96) ==3564== by 0x4EE1DB7: gopherRead (gopher.cpp:655) ==3564== by 0x40BCA3: testReadInner(char const*) (in /root/Gopher/test/python-test/multiProcess/writeWithPara) ==3564== by 0x40C4AD: testRead() (in /root/Gopher/test/python-test/multiProcess/writeWithPara) ==3564== by 0x40C888: main (in /root/Gopher/test/python-test/multiProcess/writeWithPara) ==3564== Address 0x1ffebff5d8 is on thread 1's stack ==3564== in frame #5, created by testReadInner(char const*) (???:)
这是 `valgrind` 工具提供的一条内存错误信息。根据错误信息显示,这是一个无效的大小为8字节的写入操作(Invalid write of size 8)。
根据堆栈跟踪信息,问题出现在 `memcpy` 函数中,该函数通常用于在内存之间进行数据拷贝。具体来说,在 `BufferedBlockInStream.cpp` 文件的第124行调用了 `memcpy` 函数,导致了无效的写入操作。
这种错误通常发生在以下情况下:
1. 内存越界:在访问数组、指针或使用 `memcpy` 进行拷贝时,超出了有效内存范围。
2. 释放后使用:在释放了内存后,仍然尝试对其进行读写操作。
3. 栈溢出:在栈空间中分配了大量数据,超过了栈的容量。
你需要检查代码中涉及的相关代码段,特别是 `BufferedBlockInStream.cpp` 文件中第124行的代码,以及涉及该代码的其他地方。
使用 `valgrind` 的 `--track-origins=yes` 选项可以提供更多关于错误来源的信息,你可以尝试添加该选项来获得更详细的错误报告。
请注意,这只是一个指导,你需要仔细检查代码以找到并解决问题。
阅读全文