(self, threads)
| 119 | param_names = ["threads"] |
| 120 | |
| 121 | def setup(self, threads): |
| 122 | size = 2**22 |
| 123 | ngroups = 10**3 |
| 124 | data = Series(np.random.randint(0, ngroups, size=size)) |
| 125 | |
| 126 | @run_parallel(num_threads=threads) |
| 127 | def get_groups(): |
| 128 | data.groupby(data).groups |
| 129 | |
| 130 | self.get_groups = get_groups |
| 131 | |
| 132 | def time_get_groups(self, threads): |
| 133 | self.get_groups() |