| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,33 @@ | ||
| import unittest | ||
| from threading import Thread | ||
| from test.support import threading_helper | ||
| from operator import methodcaller | ||
|
|
||
|
|
||
| class TestMethodcaller(unittest.TestCase): | ||
| def test_methodcaller_threading(self): | ||
| number_of_threads = 10 | ||
| size = 4_000 | ||
|
|
||
| mc = methodcaller("append", 2) | ||
|
|
||
| def work(mc, l, ii): | ||
| for _ in range(ii): | ||
| mc(l) | ||
|
|
||
| worker_threads = [] | ||
| lists = [] | ||
| for ii in range(number_of_threads): | ||
| l = [] | ||
| lists.append(l) | ||
| worker_threads.append(Thread(target=work, args=[mc, l, size])) | ||
| for t in worker_threads: | ||
| t.start() | ||
| for t in worker_threads: | ||
| t.join() | ||
| for l in lists: | ||
| assert len(l) == size | ||
|
|
||
|
|
||
| if __name__ == "__main__": | ||
| unittest.main() |
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1 @@ | ||
| Make :func:`operator.methodcaller` thread-safe and re-entrant safe. |
| Back | FazBrowse Home | New Git URL |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Choose a reason Spam Abuse Off Topic Outdated Duplicate Resolved Low QualityNote mc->vectorcall_kwnames is a tuple of strings, but the strings can be subclasses of str, so we need to visit this.
Sorry, something went wrong.
Uh oh!
There was an error while loading. Please reload this page.