[C++] Остановить чтение файла из параллельного потока

man signal

То бишь, разумеется, man pthread_kill. Что-то я не того.

В смысле QThread::terminate. Не кошерно, так как деструкторы не позовутся, память потечёт и т. д.

Ой, блин. ну правда, неужели совсем разучились думать читать и учиться ?

shm_open(shmfd)
while(1) {
 lseek(shmfd, 0)
 c = read(shmfd, 1)
 if (c) 
  exit(1);
 /* read file */
}

Да и вообще, любой механизм IPC подойдет....

>Ой, блин. ну правда, неужели совсем разучились думать читать и учиться ?

Ой, блин. ну правда, неужели совсем разучились читать текст вопроса ?

Проблема как раз таки в коде /* read file */, который ступорится, ожидая ввода, и который нужно из этого состояния вывести. Как послать сообщение, я и сам разобрался.

Входной файл состоит из записей
если файл является fifo

можно открыть fifo и записать тута «хитрую» запись, которая не валидна как запись, но означает, что потоку надо бы того, домой.

как вариант aio_read/aio_suspend с таймаутом.

Неблокирующий I/O, это же очевидно :)
man select

>aio_read/aio_suspend

Похоже, то, что мне нужно, называется асинхронный ввод.вывод. Буду смотреть в сторону asio.

>man select

Нужно что-то вроде системного вызова select, но на потоках.

Ну да, ну да.

Почему не подходит просто select?
Селектишь из двух дескрипторов: в одном читаешь файл/фифо, в другом ожидаешь пинка со стороны GUI.

aio реально не нужен. Достаточно неблокирующего ИО :)

>Почему не подходит просто select?

Boost.streams используется для прозрачной работы с компрессией. Можно, конечно, реализовать свой streambuf, который делает как раз-таки это, но, возможно, это кем-то уже сделано.

aio реально не нужен. Достаточно неблокирующего ИО :)

Тогда придётся висеть в цикле, пытаясь прочитать следующий байт, пока не придёт сообщение.

Если вам нужно немедленное завершение чтения файла, то смотрите в сторону сигналов. Написать обработку так, чтобы на сигнал реагировал только один поток совсем не сложно.

а Boost.streams не может выдать хэндл, который подойдет для select ?

В идеале нужно что-то вроде InterruptibleChannel из Java. Можно попробовать написать самому, но может в Boost'е уже есть что-то подобное?

http://www.boost.org/doc/libs/1_47_0/libs/iostreams/doc/index.html

ненавижу

В Boost.iostreams, насколько я понял, всё синхронное. По крайней мере, беглый обзор reference не выдаёт ничего подходящего. А что конкретно вызывает ненависть?

ненавижу писателей подобных сраных streams, потому что они говно

хочешь жить как людь - пиши свои классы, отдельные от убогих реализаций.

class FileReader : public QObject {
    Q_OBJECT

public:
    FileReader(const char *filename)
        : QObject(0)
    {
        int handle = ::open(filename, O_NONBLOCK | O_RDWR);
        m_notifier = new QSocketNotifier(handle, QSocketNotifier::Read, this);
        m_notifier->setEnabled(true);

        connect(m_notifier, SIGNAL(activated(int)), SLOT(readFile(int)));
    }

    ~FileReader() {
        qDebug() << Q_FUNC_INFO << ::close(m_notifier->socket());
    }

private slots:
    void readFile(int fd) {
        m_notifier->setEnabled(false);
        {
            QFile file;
            if (file.open(fd, QFile::ReadOnly)) {
                qDebug() << file.readAll();
            }
        }
        m_notifier->setEnabled(true);
    }

private:
    QSocketNotifier *m_notifier;
};

Фигота конечно, и вроде как QSocketNotifier не гарантируют корректную работу с pipe'ами.

И хрень с QFile лучше наверное таки заменить на обычный ::read.

Лучше взять Boost.ASIO

Сделать для этого потока io_service, запустить туда тред, читать файл/пайп через async_read/async_read_until (там есть posix::stream_descriptor для заворачивания файловых дескрипторов), а когда надо убить, делать io_service.reset(), completion_handler будет вызван с boost::asio::error::operation_aborted.

Пардон, io_service.stop(), а не reset() или stream_descriptor.cancel()

Пока не напишу, не буду отмечать как решённую. Либо возьму Asio, либо попробую написать прерываемый фильтр для boost iostreams.

Лучше уж pselect() тогда чтоб не переходить в busy-wait.

select() has no sigmask argument, and behaves as pselect() called with NULL sigmask.

Проще всего закрыть файловый дескриптор, который читает другой поток исполнения. Тогда системный вызов read() в том потоке вернёт ошибку EBADF.

> Тогда системный вызов read() в том потоке вернёт ошибку EBADF.

Гонка же. Следующий открытый файл рискует занять тот же номер и будет не EBADF, а кошмар.

Boost.asio вряд ли подойдёт. Хотя там и есть потоки, но асинхронно они только сообщяются с сокетами, операции чтения/записи из потока такие же блокирующие. Нельзя заставить эту операцию прерваться и кинуть исключение.

Остаётся вариант с реализацией streambuf с aio внутри.