ramjet 1.2.1

Scripts Manager

Ramjet
===

[]()
[](https://badge.fury.io/py/ramjet)
[]()
[](http://commitizen.github.io/cz-cli/)

> わが征くは星の大海 —— Yang Wen-li

|  |
|:--:|
| 后台脚本的引擎 |


## Links

- [Documents](http://laisky.github.io/ramjet/)
- [Github](https://github.com/Laisky/ramjet)
- [PyPI](https://pypi.python.org/pypi/ramjet)


## Install & Run

Need Python3.5.x.

```sh
# Install from pypi

$ pip install ramjet
```

```sh
# Install from source

$ python setup.py install
$ python -m ramjet [--debug=true]
```


## Description

基于 asyncio 和 consurrent.futures 运行脚本（`tasks`）。

每一个 task 都需要实现接口 `bind_task()`。

利用 `ioloop`、`thread_executor`、`process_executor` 自行实现运行逻辑。


## Demo

### 异步

```py
from ramjet.engines import process_executor, thread_executor, ioloop


def bind_task():
# 将任务添加进事件循环中
ioloop.add_future(async_task(), callback)


@tornado.gen.coroutine
def async_task():
yield tornado.gen.sleep(3)
yield async_child_task()


@tornado.gen.coroutine
def async_child_task():
yield tornado.gen.sleep(1)
print('child task ok!')


def callback(future):
print('ok')

```

### 多线程 & 多进程

需要注意子进程没法回收，所以请确保 task 可以很好的结束。

```py
from ramjet.engines import process_executor, thread_executor, ioloop


def bind_task():
# 多线程
thread_executor.submit(task, your_arguments)
# 多进程
process_executor.submit(task, your_arguments)


def task(*args, **kw):
pass

```

### 定时任务

```
from ramjet.engines import process_executor, thread_executor, ioloop


def bind_task():
now = ioloop.time()
run_at = now + 3600
ioloop.call_at(run_at, task, your_auguments)


def task(*args, **kw):
# 可以在 task 内设置下一次执行的时间
# ioloop.run_at(run_at, task, *args, **kw)
```

## Versions

[更新日志](https://github.com/Laisky/ramjet/blob/master/CHANGELOG.md)