mirror of https://github.com/python/cpython
219 lines
6.5 KiB
C
219 lines
6.5 KiB
C
/*[clinic input]
|
|
preserve
|
|
[clinic start generated code]*/
|
|
|
|
PyDoc_STRVAR(simplequeue_new__doc__,
|
|
"SimpleQueue()\n"
|
|
"--\n"
|
|
"\n"
|
|
"Simple, unbounded, reentrant FIFO queue.");
|
|
|
|
static PyObject *
|
|
simplequeue_new_impl(PyTypeObject *type);
|
|
|
|
static PyObject *
|
|
simplequeue_new(PyTypeObject *type, PyObject *args, PyObject *kwargs)
|
|
{
|
|
PyObject *return_value = NULL;
|
|
|
|
if ((type == &PySimpleQueueType) &&
|
|
!_PyArg_NoPositional("SimpleQueue", args)) {
|
|
goto exit;
|
|
}
|
|
if ((type == &PySimpleQueueType) &&
|
|
!_PyArg_NoKeywords("SimpleQueue", kwargs)) {
|
|
goto exit;
|
|
}
|
|
return_value = simplequeue_new_impl(type);
|
|
|
|
exit:
|
|
return return_value;
|
|
}
|
|
|
|
PyDoc_STRVAR(_queue_SimpleQueue_put__doc__,
|
|
"put($self, /, item, block=True, timeout=None)\n"
|
|
"--\n"
|
|
"\n"
|
|
"Put the item on the queue.\n"
|
|
"\n"
|
|
"The optional \'block\' and \'timeout\' arguments are ignored, as this method\n"
|
|
"never blocks. They are provided for compatibility with the Queue class.");
|
|
|
|
#define _QUEUE_SIMPLEQUEUE_PUT_METHODDEF \
|
|
{"put", (PyCFunction)_queue_SimpleQueue_put, METH_FASTCALL|METH_KEYWORDS, _queue_SimpleQueue_put__doc__},
|
|
|
|
static PyObject *
|
|
_queue_SimpleQueue_put_impl(simplequeueobject *self, PyObject *item,
|
|
int block, PyObject *timeout);
|
|
|
|
static PyObject *
|
|
_queue_SimpleQueue_put(simplequeueobject *self, PyObject *const *args, Py_ssize_t nargs, PyObject *kwnames)
|
|
{
|
|
PyObject *return_value = NULL;
|
|
static const char * const _keywords[] = {"item", "block", "timeout", NULL};
|
|
static _PyArg_Parser _parser = {"O|pO:put", _keywords, 0};
|
|
PyObject *item;
|
|
int block = 1;
|
|
PyObject *timeout = Py_None;
|
|
|
|
if (!_PyArg_ParseStackAndKeywords(args, nargs, kwnames, &_parser,
|
|
&item, &block, &timeout)) {
|
|
goto exit;
|
|
}
|
|
return_value = _queue_SimpleQueue_put_impl(self, item, block, timeout);
|
|
|
|
exit:
|
|
return return_value;
|
|
}
|
|
|
|
PyDoc_STRVAR(_queue_SimpleQueue_put_nowait__doc__,
|
|
"put_nowait($self, /, item)\n"
|
|
"--\n"
|
|
"\n"
|
|
"Put an item into the queue without blocking.\n"
|
|
"\n"
|
|
"This is exactly equivalent to `put(item)` and is only provided\n"
|
|
"for compatibility with the Queue class.");
|
|
|
|
#define _QUEUE_SIMPLEQUEUE_PUT_NOWAIT_METHODDEF \
|
|
{"put_nowait", (PyCFunction)_queue_SimpleQueue_put_nowait, METH_FASTCALL|METH_KEYWORDS, _queue_SimpleQueue_put_nowait__doc__},
|
|
|
|
static PyObject *
|
|
_queue_SimpleQueue_put_nowait_impl(simplequeueobject *self, PyObject *item);
|
|
|
|
static PyObject *
|
|
_queue_SimpleQueue_put_nowait(simplequeueobject *self, PyObject *const *args, Py_ssize_t nargs, PyObject *kwnames)
|
|
{
|
|
PyObject *return_value = NULL;
|
|
static const char * const _keywords[] = {"item", NULL};
|
|
static _PyArg_Parser _parser = {"O:put_nowait", _keywords, 0};
|
|
PyObject *item;
|
|
|
|
if (!_PyArg_ParseStackAndKeywords(args, nargs, kwnames, &_parser,
|
|
&item)) {
|
|
goto exit;
|
|
}
|
|
return_value = _queue_SimpleQueue_put_nowait_impl(self, item);
|
|
|
|
exit:
|
|
return return_value;
|
|
}
|
|
|
|
PyDoc_STRVAR(_queue_SimpleQueue_get__doc__,
|
|
"get($self, /, block=True, timeout=None)\n"
|
|
"--\n"
|
|
"\n"
|
|
"Remove and return an item from the queue.\n"
|
|
"\n"
|
|
"If optional args \'block\' is true and \'timeout\' is None (the default),\n"
|
|
"block if necessary until an item is available. If \'timeout\' is\n"
|
|
"a non-negative number, it blocks at most \'timeout\' seconds and raises\n"
|
|
"the Empty exception if no item was available within that time.\n"
|
|
"Otherwise (\'block\' is false), return an item if one is immediately\n"
|
|
"available, else raise the Empty exception (\'timeout\' is ignored\n"
|
|
"in that case).");
|
|
|
|
#define _QUEUE_SIMPLEQUEUE_GET_METHODDEF \
|
|
{"get", (PyCFunction)_queue_SimpleQueue_get, METH_FASTCALL|METH_KEYWORDS, _queue_SimpleQueue_get__doc__},
|
|
|
|
static PyObject *
|
|
_queue_SimpleQueue_get_impl(simplequeueobject *self, int block,
|
|
PyObject *timeout);
|
|
|
|
static PyObject *
|
|
_queue_SimpleQueue_get(simplequeueobject *self, PyObject *const *args, Py_ssize_t nargs, PyObject *kwnames)
|
|
{
|
|
PyObject *return_value = NULL;
|
|
static const char * const _keywords[] = {"block", "timeout", NULL};
|
|
static _PyArg_Parser _parser = {"|pO:get", _keywords, 0};
|
|
int block = 1;
|
|
PyObject *timeout = Py_None;
|
|
|
|
if (!_PyArg_ParseStackAndKeywords(args, nargs, kwnames, &_parser,
|
|
&block, &timeout)) {
|
|
goto exit;
|
|
}
|
|
return_value = _queue_SimpleQueue_get_impl(self, block, timeout);
|
|
|
|
exit:
|
|
return return_value;
|
|
}
|
|
|
|
PyDoc_STRVAR(_queue_SimpleQueue_get_nowait__doc__,
|
|
"get_nowait($self, /)\n"
|
|
"--\n"
|
|
"\n"
|
|
"Remove and return an item from the queue without blocking.\n"
|
|
"\n"
|
|
"Only get an item if one is immediately available. Otherwise\n"
|
|
"raise the Empty exception.");
|
|
|
|
#define _QUEUE_SIMPLEQUEUE_GET_NOWAIT_METHODDEF \
|
|
{"get_nowait", (PyCFunction)_queue_SimpleQueue_get_nowait, METH_NOARGS, _queue_SimpleQueue_get_nowait__doc__},
|
|
|
|
static PyObject *
|
|
_queue_SimpleQueue_get_nowait_impl(simplequeueobject *self);
|
|
|
|
static PyObject *
|
|
_queue_SimpleQueue_get_nowait(simplequeueobject *self, PyObject *Py_UNUSED(ignored))
|
|
{
|
|
return _queue_SimpleQueue_get_nowait_impl(self);
|
|
}
|
|
|
|
PyDoc_STRVAR(_queue_SimpleQueue_empty__doc__,
|
|
"empty($self, /)\n"
|
|
"--\n"
|
|
"\n"
|
|
"Return True if the queue is empty, False otherwise (not reliable!).");
|
|
|
|
#define _QUEUE_SIMPLEQUEUE_EMPTY_METHODDEF \
|
|
{"empty", (PyCFunction)_queue_SimpleQueue_empty, METH_NOARGS, _queue_SimpleQueue_empty__doc__},
|
|
|
|
static int
|
|
_queue_SimpleQueue_empty_impl(simplequeueobject *self);
|
|
|
|
static PyObject *
|
|
_queue_SimpleQueue_empty(simplequeueobject *self, PyObject *Py_UNUSED(ignored))
|
|
{
|
|
PyObject *return_value = NULL;
|
|
int _return_value;
|
|
|
|
_return_value = _queue_SimpleQueue_empty_impl(self);
|
|
if ((_return_value == -1) && PyErr_Occurred()) {
|
|
goto exit;
|
|
}
|
|
return_value = PyBool_FromLong((long)_return_value);
|
|
|
|
exit:
|
|
return return_value;
|
|
}
|
|
|
|
PyDoc_STRVAR(_queue_SimpleQueue_qsize__doc__,
|
|
"qsize($self, /)\n"
|
|
"--\n"
|
|
"\n"
|
|
"Return the approximate size of the queue (not reliable!).");
|
|
|
|
#define _QUEUE_SIMPLEQUEUE_QSIZE_METHODDEF \
|
|
{"qsize", (PyCFunction)_queue_SimpleQueue_qsize, METH_NOARGS, _queue_SimpleQueue_qsize__doc__},
|
|
|
|
static Py_ssize_t
|
|
_queue_SimpleQueue_qsize_impl(simplequeueobject *self);
|
|
|
|
static PyObject *
|
|
_queue_SimpleQueue_qsize(simplequeueobject *self, PyObject *Py_UNUSED(ignored))
|
|
{
|
|
PyObject *return_value = NULL;
|
|
Py_ssize_t _return_value;
|
|
|
|
_return_value = _queue_SimpleQueue_qsize_impl(self);
|
|
if ((_return_value == -1) && PyErr_Occurred()) {
|
|
goto exit;
|
|
}
|
|
return_value = PyLong_FromSsize_t(_return_value);
|
|
|
|
exit:
|
|
return return_value;
|
|
}
|
|
/*[clinic end generated code: output=8badc3bb85263689 input=a9049054013a1b77]*/
|