pathos の API リファレンス
pathos (uqfoundation/pathos) の公開 API 59 件 —— クラス 17、関数 11、メソッド 31。実際のソースを静的解析して抽出した正確なシグネチャを掲載しています。
リポジトリ: uqfoundation/pathos
| 種別 | 件数 |
|---|---|
| クラス | 17 |
| 関数 | 11 |
| メソッド | 31 |
API 一覧
func
examples2.all_scatter_gather.sin2(xi)sin squared of all data
func
examples2.all_scatter_gather2.sin_diff(x, xp)d = sin(x - x')
class
pathos.abstract_launcher.AbstractPipeConnectionAbstractPipeConnection base class for pathos pipes.
class
pathos.abstract_launcher.AbstractWorkerPoolAbstractWorkerPool base class for pathos pools.
method
pathos.abstract_launcher.AbstractWorkerPool.clear()Remove server with matching state
func
pathos.citation()print citation
class
pathos.connection.Pipea popen-based pipe for parallel and distributed computing
method
pathos.connection.Pipe.kill()terminate the pipe
method
pathos.connection.Pipe.launch()launch a configured command
method
pathos.connection.Pipe.pid()get pipe pid
class
pathos.connection.PipeExceptionException for failure to launch a command
func
pathos.helpers.mp_helper.random_seed(s=None)sets the seed for calls to 'random()'
func
pathos.hosts.get_profiles()get $PROFILE for each registered host
func
pathos.hosts.register(rhost, profile=None)register a host and $PROFILE
func
pathos.license()print license
method
pathos.maps.Map.clear()remove pool singleton, if exists
method
pathos.maps.Map.close()close the map to any new jobs
method
pathos.maps.Map.join()reclaim the closed workers
class
pathos.multiprocessing.ProcessPoolMapper that leverages python's multiprocessing.
method
pathos.multiprocessing.ProcessPool.close()close the pool to any new jobs
method
pathos.multiprocessing.ProcessPool.join()cleanup the closed worker processes
method
pathos.multiprocessing.ProcessPool.restart(force=False)restart a closed pool
method
pathos.multiprocessing.ProcessPool.terminate()a more abrupt close
class
pathos.parallel.ParallelPoolMapper that leverages parallelpython (i.e.
method
pathos.parallel.ParallelPool.close()close the pool to any new jobs
func
pathos.parallel.ParallelPool.imap_unordered(it)build a unordered map iterator
method
pathos.parallel.ParallelPool.join()cleanup the closed worker processes
method
pathos.parallel.ParallelPool.restart(force=False)restart a closed pool
func
pathos.parallel.ParallelPool.submit(*argz)send a job to the server
method
pathos.parallel.ParallelPool.terminate()a more abrupt close
func
pathos.pp_map.submit(*args)Send a job to the server
class
pathos.profile.profiledecorator for profiling a function (will enable profiling)
func
pathos.profile.thread_id()get the identifier for the current thread
class
pathos.secure.connection.Pipea popen-based ssh-pipe for parallel and distributed computing.
class
pathos.secure.copier.Copiera popen-based copier for parallel and distributed computing.
class
pathos.secure.copier.FileNotFoundException for improper source or destination format
class
pathos.secure.tunnel.Tunnela ssh-tunnel launcher for parallel and distributed computing.
method
pathos.secure.tunnel.Tunnel.disconnect()destroy the ssh tunnel
class
pathos.secure.tunnel.TunnelExceptionException for failure to establish ssh tunnel
class
pathos.selector.SelectorSelector object for watching and event notification.
class
pathos.serial.SerialPoolMapper that leverages standard (i.e.
method
pathos.serial.SerialPool.clear()hard restart
method
pathos.serial.SerialPool.close()close the pool to any new jobs
method
pathos.serial.SerialPool.join()cleanup the closed worker processes
method
pathos.serial.SerialPool.restart(force=False)restart a closed pool
method
pathos.serial.SerialPool.terminate()a more abrupt close
method
pathos.server.Server.deactivate()turn off the selector
method
pathos.server.Server.selector()get the selector
method
pathos.server.Server.serve(timeout)begin serving, and set the timeout
class
pathos.threading.ThreadPoolMapper that leverages python's threading.
method
pathos.threading.ThreadPool.close()close the pool to any new jobs
method
pathos.threading.ThreadPool.join()cleanup the closed worker processes
method
pathos.threading.ThreadPool.restart(force=False)restart a closed pool
method
pathos.threading.ThreadPool.terminate()a more abrupt close
class
pathos.xmlrpc.server.XMLRPCRequestHandlercreate a XML-RPC request handler
method
pathos.xmlrpc.server.XMLRPCRequestHandler.do_POST()Access point from HTTP handler
class
pathos.xmlrpc.server.XMLRPCServerextends base pathos server to an XML-RPC dispatcher
method
pathos.xmlrpc.server.XMLRPCServer.activate()install callbacks
method
pathos.xmlrpc.server.XMLRPCServer.serve()enter the select loop...
この情報について
掲載しているシグネチャは uqfoundation/pathos の公開ソースコードを
Python の ast モジュールで静的解析し、引数名・デフォルト値・
型注釈・戻り値型をそのまま抽出したものです。実装コードは保存していません。
詳しくは仕組みの解説をご覧ください。