(green_thread, *args, **kwargs)
| 105 | |
| 106 | |
| 107 | def cancel(green_thread, *args, **kwargs): |
| 108 | if CONCURRENCY_LIBRARY == "eventlet": |
| 109 | return green_thread.cancel(*args, **kwargs) |
| 110 | elif CONCURRENCY_LIBRARY == "gevent": |
| 111 | return green_thread.kill(*args, **kwargs) |
| 112 | else: |
| 113 | raise ValueError("Unsupported concurrency library") |
| 114 | |
| 115 | |
| 116 | def kill(green_thread, *args, **kwargs): |