| /dports/devel/py-bullet3/bullet3-3.21/examples/pybullet/gym/pybullet_envs/examples/ |
| H A D | batchsim3.py | 107 num_processes = 1 variable
109 num_processes = 12
111 args=[0]*num_processes
116 for pr in range(num_processes):
121 for rank in range(num_processes):
130 positive_rewards = [0]*num_processes
131 for k in range(num_processes):
139 for k in range(num_processes):
148 for k in range(num_processes):
157 for k in range(num_processes):
[all …]
|
| /dports/devel/py-bullet3/bullet3-3.21/examples/pybullet/gym/pybullet_robots/panda/ |
| H A D | batchsim3.py | 107 num_processes = 1 variable
109 num_processes = 12
111 args=[0]*num_processes
116 for pr in range(num_processes):
121 for rank in range(num_processes):
130 positive_rewards = [0]*num_processes
131 for k in range(num_processes):
139 for k in range(num_processes):
148 for k in range(num_processes):
157 for k in range(num_processes):
[all …]
|
| H A D | batchsim3_grasp.py | 107 num_processes = 1 variable
109 num_processes = 12
111 args=[0]*num_processes
116 for pr in range(num_processes):
121 for rank in range(num_processes):
130 positive_rewards = [0]*num_processes
131 for k in range(num_processes):
138 for k in range(num_processes):
145 for k in range(num_processes):
154 for k in range(num_processes):
[all …]
|
| /dports/science/py-dipy/dipy-1.4.1/dipy/utils/ |
| H A D | multiproc.py | 7 def determine_num_processes(num_processes): argument
26 if not isinstance(num_processes, int) and num_processes is not None:
29 if num_processes == 0:
33 if num_processes is None:
36 if num_processes < 0:
37 return max(1, cpu_count() + num_processes + 1)
42 return num_processes
|
| /dports/devel/py-cluster/python-cluster-1.4.1/cluster/ |
| H A D | matrix.py | 107 def genmatrix(self, num_processes=1): argument
116 use_multiprocessing = num_processes > 1
124 logger.info("Using multiprocessing on %s processes!", num_processes)
127 logger.info("Spinning up %s workers", num_processes)
128 processes = [Process(target=self.worker) for i in range(num_processes)]
156 if num_tasks_queued > num_processes:
194 logger.info("Stopping/joining %s workers", num_processes)
195 [self.task_queue.put('STOP') for i in range(num_processes)]
|
| /dports/devel/boost-docs/boost_1_72_0/boost/property_map/parallel/ |
| H A D | global_index_map.hpp | 33 starting_index.reset(new std::vector<value_type>(num_processes(pg) + 1)); in global_index_map()
40 for (process_id_type src = 0; src < num_processes(pg); ++src) { in global_index_map()
45 for (process_id_type dest = 1; dest < num_processes(pg); ++dest) in global_index_map()
46 send(pg, dest, 1, &starting_index->front(), num_processes(pg)); in global_index_map()
50 receive(pg, 0, 1, &starting_index->front(), num_processes(pg)); in global_index_map()
|
| /dports/devel/R-cran-BH/BH/inst/include/boost/property_map/parallel/ |
| H A D | global_index_map.hpp | 33 starting_index.reset(new std::vector<value_type>(num_processes(pg) + 1)); in global_index_map()
40 for (process_id_type src = 0; src < num_processes(pg); ++src) { in global_index_map()
45 for (process_id_type dest = 1; dest < num_processes(pg); ++dest) in global_index_map()
46 send(pg, dest, 1, &starting_index->front(), num_processes(pg)); in global_index_map()
50 receive(pg, 0, 1, &starting_index->front(), num_processes(pg)); in global_index_map()
|
| /dports/databases/percona57-pam-for-mysql/boost_1_59_0/boost/property_map/parallel/ |
| H A D | global_index_map.hpp | 33 starting_index.reset(new std::vector<value_type>(num_processes(pg) + 1)); in global_index_map()
40 for (process_id_type src = 0; src < num_processes(pg); ++src) { in global_index_map()
45 for (process_id_type dest = 1; dest < num_processes(pg); ++dest) in global_index_map()
46 send(pg, dest, 1, &starting_index->front(), num_processes(pg)); in global_index_map()
50 receive(pg, 0, 1, &starting_index->front(), num_processes(pg)); in global_index_map()
|
| /dports/math/stanmath/math-4.2.0/lib/boost_1.75.0/boost/property_map/parallel/ |
| H A D | global_index_map.hpp | 33 starting_index.reset(new std::vector<value_type>(num_processes(pg) + 1)); in global_index_map()
40 for (process_id_type src = 0; src < num_processes(pg); ++src) { in global_index_map()
45 for (process_id_type dest = 1; dest < num_processes(pg); ++dest) in global_index_map()
46 send(pg, dest, 1, &starting_index->front(), num_processes(pg)); in global_index_map()
50 receive(pg, 0, 1, &starting_index->front(), num_processes(pg)); in global_index_map()
|
| /dports/science/py-scipy/scipy-1.7.1/scipy/_lib/boost/boost/property_map/parallel/ |
| H A D | global_index_map.hpp | 33 starting_index.reset(new std::vector<value_type>(num_processes(pg) + 1));
40 for (process_id_type src = 0; src < num_processes(pg); ++src) {
45 for (process_id_type dest = 1; dest < num_processes(pg); ++dest)
46 send(pg, dest, 1, &starting_index->front(), num_processes(pg));
50 receive(pg, 0, 1, &starting_index->front(), num_processes(pg));
|
| /dports/databases/xtrabackup/boost_1_59_0/boost/property_map/parallel/ |
| H A D | global_index_map.hpp | 33 starting_index.reset(new std::vector<value_type>(num_processes(pg) + 1)); in global_index_map()
40 for (process_id_type src = 0; src < num_processes(pg); ++src) { in global_index_map()
45 for (process_id_type dest = 1; dest < num_processes(pg); ++dest) in global_index_map()
46 send(pg, dest, 1, &starting_index->front(), num_processes(pg)); in global_index_map()
50 receive(pg, 0, 1, &starting_index->front(), num_processes(pg)); in global_index_map()
|
| /dports/databases/percona57-server/boost_1_59_0/boost/property_map/parallel/ |
| H A D | global_index_map.hpp | 33 starting_index.reset(new std::vector<value_type>(num_processes(pg) + 1)); in global_index_map()
40 for (process_id_type src = 0; src < num_processes(pg); ++src) { in global_index_map()
45 for (process_id_type dest = 1; dest < num_processes(pg); ++dest) in global_index_map()
46 send(pg, dest, 1, &starting_index->front(), num_processes(pg)); in global_index_map()
50 receive(pg, 0, 1, &starting_index->front(), num_processes(pg)); in global_index_map()
|
| /dports/math/deal.ii/dealii-803d21ff957e349b3799cd3ef2c840bc78734305/bundled/boost-1.70.0/include/boost/property_map/parallel/ |
| H A D | global_index_map.hpp | 33 starting_index.reset(new std::vector<value_type>(num_processes(pg) + 1)); in global_index_map()
40 for (process_id_type src = 0; src < num_processes(pg); ++src) { in global_index_map()
45 for (process_id_type dest = 1; dest < num_processes(pg); ++dest) in global_index_map()
46 send(pg, dest, 1, &starting_index->front(), num_processes(pg)); in global_index_map()
50 receive(pg, 0, 1, &starting_index->front(), num_processes(pg)); in global_index_map()
|
| /dports/databases/percona57-client/boost_1_59_0/boost/property_map/parallel/ |
| H A D | global_index_map.hpp | 33 starting_index.reset(new std::vector<value_type>(num_processes(pg) + 1)); in global_index_map()
40 for (process_id_type src = 0; src < num_processes(pg); ++src) { in global_index_map()
45 for (process_id_type dest = 1; dest < num_processes(pg); ++dest) in global_index_map()
46 send(pg, dest, 1, &starting_index->front(), num_processes(pg)); in global_index_map()
50 receive(pg, 0, 1, &starting_index->front(), num_processes(pg)); in global_index_map()
|
| /dports/security/keybase/client-v5.7.1/shared/ios/Pods/boost-for-react-native/boost/property_map/parallel/ |
| H A D | global_index_map.hpp | 33 starting_index.reset(new std::vector<value_type>(num_processes(pg) + 1)); in global_index_map()
40 for (process_id_type src = 0; src < num_processes(pg); ++src) { in global_index_map()
45 for (process_id_type dest = 1; dest < num_processes(pg); ++dest) in global_index_map()
46 send(pg, dest, 1, &starting_index->front(), num_processes(pg)); in global_index_map()
50 receive(pg, 0, 1, &starting_index->front(), num_processes(pg)); in global_index_map()
|
| /dports/devel/boost-libs/boost_1_72_0/boost/property_map/parallel/ |
| H A D | global_index_map.hpp | 33 starting_index.reset(new std::vector<value_type>(num_processes(pg) + 1)); in global_index_map()
40 for (process_id_type src = 0; src < num_processes(pg); ++src) { in global_index_map()
45 for (process_id_type dest = 1; dest < num_processes(pg); ++dest) in global_index_map()
46 send(pg, dest, 1, &starting_index->front(), num_processes(pg)); in global_index_map()
50 receive(pg, 0, 1, &starting_index->front(), num_processes(pg)); in global_index_map()
|
| /dports/devel/boost-python-libs/boost_1_72_0/boost/property_map/parallel/ |
| H A D | global_index_map.hpp | 33 starting_index.reset(new std::vector<value_type>(num_processes(pg) + 1)); in global_index_map()
40 for (process_id_type src = 0; src < num_processes(pg); ++src) { in global_index_map()
45 for (process_id_type dest = 1; dest < num_processes(pg); ++dest) in global_index_map()
46 send(pg, dest, 1, &starting_index->front(), num_processes(pg)); in global_index_map()
50 receive(pg, 0, 1, &starting_index->front(), num_processes(pg)); in global_index_map()
|
| /dports/databases/mysql57-client/mysql-5.7.36/boost/boost_1_59_0/boost/property_map/parallel/ |
| H A D | global_index_map.hpp | 33 starting_index.reset(new std::vector<value_type>(num_processes(pg) + 1)); in global_index_map()
40 for (process_id_type src = 0; src < num_processes(pg); ++src) { in global_index_map()
45 for (process_id_type dest = 1; dest < num_processes(pg); ++dest) in global_index_map()
46 send(pg, dest, 1, &starting_index->front(), num_processes(pg)); in global_index_map()
50 receive(pg, 0, 1, &starting_index->front(), num_processes(pg)); in global_index_map()
|
| /dports/databases/mysqlwsrep57-server/boost_1_59_0/boost/property_map/parallel/ |
| H A D | global_index_map.hpp | 33 starting_index.reset(new std::vector<value_type>(num_processes(pg) + 1)); in global_index_map()
40 for (process_id_type src = 0; src < num_processes(pg); ++src) { in global_index_map()
45 for (process_id_type dest = 1; dest < num_processes(pg); ++dest) in global_index_map()
46 send(pg, dest, 1, &starting_index->front(), num_processes(pg)); in global_index_map()
50 receive(pg, 0, 1, &starting_index->front(), num_processes(pg)); in global_index_map()
|
| /dports/math/py-pystan/pystan-2.19.0.0/pystan/stan/lib/stan_math/lib/boost_1.69.0/boost/property_map/parallel/ |
| H A D | global_index_map.hpp | 33 starting_index.reset(new std::vector<value_type>(num_processes(pg) + 1)); in global_index_map()
40 for (process_id_type src = 0; src < num_processes(pg); ++src) { in global_index_map()
45 for (process_id_type dest = 1; dest < num_processes(pg); ++dest) in global_index_map()
46 send(pg, dest, 1, &starting_index->front(), num_processes(pg)); in global_index_map()
50 receive(pg, 0, 1, &starting_index->front(), num_processes(pg)); in global_index_map()
|
| /dports/devel/hyperscan/boost_1_75_0/boost/property_map/parallel/ |
| H A D | global_index_map.hpp | 33 starting_index.reset(new std::vector<value_type>(num_processes(pg) + 1)); in global_index_map()
40 for (process_id_type src = 0; src < num_processes(pg); ++src) { in global_index_map()
45 for (process_id_type dest = 1; dest < num_processes(pg); ++dest) in global_index_map()
46 send(pg, dest, 1, &starting_index->front(), num_processes(pg)); in global_index_map()
50 receive(pg, 0, 1, &starting_index->front(), num_processes(pg)); in global_index_map()
|
| /dports/games/frogatto/frogatto-1.3.1/MacOSJet/boost/include/boost/property_map/parallel/ |
| H A D | global_index_map.hpp | 37 starting_index.reset(new std::vector<value_type>(num_processes(pg) + 1)); in global_index_map()
44 for (process_id_type src = 0; src < num_processes(pg); ++src) { in global_index_map()
49 for (process_id_type dest = 1; dest < num_processes(pg); ++dest) in global_index_map()
50 send(pg, dest, 1, &starting_index->front(), num_processes(pg)); in global_index_map()
54 receive(pg, 0, 1, &starting_index->front(), num_processes(pg)); in global_index_map()
|
| /dports/net/mpich/mpich-3.4.3/src/pm/hydra2/libhydra/topo/hwloc/hwloc/utils/netloc/mpi/ |
| H A D | netloc_mpi_rank_file.c | 23 int num_processes; in main() local
33 ret = netlocscotch_get_mapping_from_comm_file(comm_filename, &num_processes, &cores); in main()
46 for (int p = 0; p < num_processes; p++) { in main()
53 for (int p = 0; p < num_processes; p++) { in main()
|
| /dports/net/mpich/mpich-3.4.3/modules/hwloc/utils/netloc/mpi/ |
| H A D | netloc_mpi_rank_file.c | 23 int num_processes; in main() local
33 ret = netlocscotch_get_mapping_from_comm_file(comm_filename, &num_processes, &cores); in main()
46 for (int p = 0; p < num_processes; p++) { in main()
53 for (int p = 0; p < num_processes; p++) { in main()
|
| /dports/net/mpich/mpich-3.4.3/src/pm/hydra/tools/topo/hwloc/hwloc/utils/netloc/mpi/ |
| H A D | netloc_mpi_rank_file.c | 23 int num_processes; in main() local
33 ret = netlocscotch_get_mapping_from_comm_file(comm_filename, &num_processes, &cores); in main()
46 for (int p = 0; p < num_processes; p++) { in main()
53 for (int p = 0; p < num_processes; p++) { in main()
|