Вопросы с меткой [потоки-данных]
Вопросы о потоках данных (streams) — абстракции, используемой для чтения или записи файлов, сокетов и т. п. в единой манере. Для вопросов о потоках выполнения (threads) используйте метку [многопоточность]. Для вопросов о Java 8 Stream API используйте метку [java-stream].
506
вопросов
-1
голос
0
ответов
30
показов
Используя Stream API, выделить сотрудников, пришедших в выбранном году, и среди них выявить сотрудника с максимальным значением заработной платы
Прохожу сейчас применение stream api, и пишу задачку про сортировку по году поступления на работу и нахождению максимальной з/п в этом самом году. Вот код класса Emoloyee
import java.nio.file.Files;
...
0
голосов
1
ответ
48
показов
Асинхронное копирование в купе с progressBar'om
На самом деле задача на половину выполнена, я имею готовое решение не без помощи backgoundWorker:
Функция копирования:
private void copy_file(string source_, string des)
{
...
-1
голос
0
ответов
66
показов
NetworkStream превращается в null после конструктора
У меня есть класс TcpPeer который представляет TCP сторону при конвертации с другого способа передачи данных (для этого и нужен интерфейс IPeer).
Но по неизвестной мне причине когда я вызываю read и ...
-2
голоса
0
ответов
30
показов
Почему при использовании потока FileWriter в файл записываются непонятные символы?
Подскажите, пожалуйста, почему при таком цикле в файл записываются непонятные символы?
public class Main {
public static void main(String[] args) throws IOException {
int k = 2;
...
0
голосов
1
ответ
17
показов
Как добавить ко всем дубликатам в Map суффикс
Предположим, что на вход метода приходят айдишники, одни из которых имеют суффикс, а другие нет
Set ids = [id, id::Suff]
Далее мне нужно создать Map<String, Object>, где ключом будет id.
Но ...
0
голосов
0
ответов
54
показа
Exception in thread "main" java.net.SocketException: ��������� �� ����� ����-���������� ��������� ������������� �����������
При запуске java socket сервера получаю ошибку, которую не могу прочитать. Есть идеи?
Exception in thread "main" java.net.SocketException: ��������� �� ����� ����-���������� ��������� �������...
0
голосов
1
ответ
62
показа
Аналитика по словам в процентах Java
Я немного запутался и не могу решить.
Нужно сделать аналитику по словам (сколько какое слово встречается в процентах и их количество; сверху наиболее распространенное.
аналитику по символам (сколько ...
1
голос
0
ответов
30
показов
Как частично отдавать файл на скачивание?
Есть большой набор данных в БД. PHP скрипт запрашивает по 1000 строк, где происходят сложные операции. Мне надо после запроса этих 1000 строк записать их в CSV файл и сразу отдать пользователю на ...
0
голосов
0
ответов
11
показов
При пайпе стрима с объектом респонса клиент получает не всю пачку данных
Нужно конвертировать табличку из БД в csv отчёт.
Если сразу выгрузить всю табличку одним запросом, то приложение падает т.к. заканчивается память. Решил запрашивать данные из таблички порциями по 100 ...
0
голосов
0
ответов
39
показов
Как работает BufferedReader?
Есть код:
import java.io.*;
class Main{
public static void main(String[] args) throws IOException{
BufferedReader qq = new BufferedReader(new InputStreamReader(System.in), 1);
...
0
голосов
1
ответ
23
показа
Как скипнуть строку в потоке, которая начинается с символа?
Нужна помощь более опытных коллег)
В общем, суть: считываем файл настроек и добавляем в карту. Метод делит строку по символу '=' на две строки, первая это ключ, вторая - значение. Метод не должен ...
0
голосов
0
ответов
16
показов
Метод close() и системные ресурсы
У потоков есть метод close(). Когда я читаю для чего нужен этот метод я встречаюсь с такой формулировкой: "для освобождения системных ресурсов".
Вопрос: а что такое эти "системные ...
0
голосов
0
ответов
28
показов
Не получается внести данные из файла в массив и обратно
Всем доброго времени суток .Я студент и прохожу курс программирования на с++ в институте.
Я столкнулся с такой проблемой , при написании кода к заданию (его я прикреплю ниже) программа почему-то не ...
1
голос
2
ответа
61
показ
Записать результат выполнения программы в файл
Есть код, нужно записать результат выполнения в файл , при использовании StreamWriter файл который создан в папке с кодом остается пустым, не пойму почему?
Подаскажите пожалуйста!
using System;
using ...
0
голосов
1
ответ
36
показов
Считать матрицу из файла и записать отредактировав в новый файл через файловые потоки
Задание:
Считать матрицу из файла и заменить все элементы, расположенные выше главной диагонали на нули. Результат вычисления с соответствующими комментариями записать в новый файл.
Делал через ...
0
голосов
0
ответов
12
показов
Отслеживание потоков данных
Есть несколько серверов, к которым подключаются по RDP. На этих серверах базы данных.
Как можно отслеживать большой поток трафика, в случае если кто то начет выкачивать данные из базы?
0
голосов
1
ответ
50
показов
C#. Как удалить строку из .txt файла без создания temp файлов и без полной перезаписи имеющегося файла? Возможно ли это?
Например, у меня есть файл с огромным количеством строк общим весом в 32 гигабайта. Этот файл содержит сериализованные Json объекты. Мне нужно найти строку содержащую определённый объект и ...
0
голосов
0
ответов
16
показов
Ошибки при передаче данных по Serial JS
Делаю систему динамической подсветки монитора. Есть Arduino Uno, которая по serial принимает с пк управляющий сигнал и выводит цвета на адресную светодиодную ленту (наклеена вокруг монитора), и js ...
0
голосов
1
ответ
27
показов
Как правильно остановить BinaryReader ReadChar?
Имею такой код
using (var stream = await response.Content.ReadAsStreamAsync().ConfigureAwait(false))
using (var reader = new BinaryReader(stream, Encoding.UTF8))
using (cancellationToken.Register(() =&...
0
голосов
0
ответов
10
показов
Проблемы с памятью при отправке и получении файлов (stream) blazor wasm, minimal api
net6 Тестовый проект
Поместите файл, который будет скачиваться в FileUploadDownloadBlazorWasm.MinimalApi/Resources/TestFile . Будет скачиваться первый найденный файл в этой папке.
Пытаюсь сделать ...
0
голосов
1
ответ
62
показа
В чем причина ошибки IntPredicate cannot be resolved to a type Java
Прошу помочь выполнить пример. Привожу его как есть из книги И.Н. Блинов, В.С. Романчик - JAVA FROM EPAM (2020). VSC выдает ошибку "IntPredicate cannot be resolved to a type Java(16777218)".
...
1
голос
1
ответ
73
показа
Не приходят respons-ы gRPC-клиенту на C#
Возникли трудности при создании gRPC-клиента на C#. Я работаю с TINKOFF INVEST API, который работает по интерфейсу gRPC.
Код клиента представлен ниже.
static async Task Main(string[] args)
{
...
0
голосов
1
ответ
30
показов
Задача на Stream API Java
Необходимо создать класс клиента со следующими полями:
уникальный идентификатор, имя, возраст. Также у клиента есть список телефонов. Класс телефона содержит само значение и тип (стационарный или ...
1
голос
0
ответов
23
показа
Дан файл, содержащий некоторый текст. Отредактировать файл: после каждой фразы в скобках указать число слов в ней
Только начал изучать потоки в Си. Не совсем понимаю почему при исходном файле...
This is an ordinary text with brackets that does not carry any meaning
and is intended to exist
independently, ...
1
голос
1
ответ
17
показов
в Stream получить List
имеются некоторые Paymentы от одного аккаунта другому, нужно получить: сколько раз каждый аккаунт получал Payment.
По коду:
группирую list по получателям, дальше из мапы получаю ключ, формирую list из ...
4
голоса
3
ответа
74
показа
Можно ли реализовать аналог std::endl?
Цель
Я хотел написать аналог std::endl, который бы вставлял символ '\n', но не вызывал бы .flush().
Ожидания
Я думал, что можно будет использовать запись типа std::cout << my::endl;
Что я ...
0
голосов
1
ответ
42
показа
Нужно пройти по коллекции объектов и суммировать значения поля если совпадает дата. Использовать Stream API
Нужно скомпоновать HashMap<LocalDate, Integer> из коллекции объектов, которые имеют поля LocalDateTime localDateTime и int calories.
Я написал такой код без использования Stream API:
HashMap<...
1
голос
0
ответов
44
показа
Как осуществить вывод результата работы потоков по заданному кванту времени
Я не могу придумать как сделать синхронизацию логов потоков.
Алгоритм «первый подходящий» (First-Fit) метода FCFS.
Задача: осуществить вывод состояния параллельных потоков каждый заданный квант ...
1
голос
1
ответ
91
показ
Java. Отсортировать даты по месяцам, используя Streams
У меня есть List<Date>, с датами в формате d/MMMM/yyyy, их нужно отсортировать по месяцам используя STREAM.
То есть, если есть:
4/February/2020
6/February/1990
11/April/2012
30/August/2011
8/...
0
голосов
2
ответа
35
показов
Обработка в stream объектов разных типов, имеющих общего родителя
Имеется класс
public class Person {
private String name;
private Type type;
private int age;
private Gender gender;
// конструктор, сеттеры и геттеры
public enum Type {PROFESSOR,...
0
голосов
1
ответ
41
показ
intStream Python
Решаю задачу с codewars, возникла проблема: не знаю, как запустить стрим в питоне. Вот ссылка на неё.
https://www.codewars.com/kata/5519a584a73e70fa570005f5/train/python
Подскажите, пожалуйста, как ...
0
голосов
1
ответ
143
показа
Используя Java Stream API, вывести:
Номера всех автомобилей, имеющих черный цвет или нулевой пробег. // filter + map
Количество уникальных моделей в ценовом диапазоне от 700 до 800 тыс. // distinct + filter
о656са121|LadaVesta|Blue|2000|...
0
голосов
0
ответов
33
показа
php разные потоки
Здравствуйте можете объяснить что нужно сделат, или подсказать где можно найти нормальный пример.
Задание для выполнения скриптов в разных потоках:
Что нужно сделать
Mysql БД из 5-и таблиц (названия ...
0
голосов
1
ответ
75
показов
При работе с бинарными файлами .exe вызвал срабатывание точки останова СИ
Я вызываю две эти функции(это реализовано в main): сначала добавляю данные в файл, затем считываю в массив структур и вывожу. Первая функция работает, а при вызове второй функции - "срабатывание ...
1
голос
0
ответов
15
показов
Как можно постепенно загружать картинку из stream?
У меня есть поток в котором я читаю изображение.
Я могу его отобразить, когда весь файл загружен.
Мне достаточно:
Объединить все части кода,
Создать blob объект,
Сделать на него ссылку и указать в ...
0
голосов
0
ответов
45
показов
Собственный метод в stream
Можно ли использовать собственный функциональный интрфейс в stream.
например есть список ArrayList drivers = new ArrayList();
Stream stream = drivers.stream();
stream. здесь уже вызвать свой метод не ...
1
голос
1
ответ
148
показов
Сумма четных элементов массива через стрим
Создал массив array . Хочу сложить только четные индексы массива ( элементы четных индексов)
int sum = Arrays.stream(array).filter(i -> i % 2 == 0) - фильтр фильтрует только само содержание ...
0
голосов
0
ответов
29
показов
Проверить, открыт ли stream (TCP)
public NetworkStream stream;
У меня в цикле прослушивается поток на чтение. Но при определённом условии я его закрываю:
stream.Close();
Цикл при этом не останавливается, и когда в следующей ...
-4
голоса
2
ответа
62
показа
в некоторых случаях программа не работает, чего у меня не хватает? [закрыт]
вот условие: Дан квадрат с вершинами в точках (0, 0), (0, k), (k, k), (k, 0). Вычислите
наименьшее из расстояний от точки с координатами (x, y), лежащей внутри
квадрата, до сторон данного квадрата. ...
0
голосов
1
ответ
25
показов
Здравствуйте, имеется проблема с записью объектов класса в текстовый файл [дубликат]
Имеется класс student, данные, которого нужно записать в текстовый файл. Во время компиляции программы происходит бесконечная запись в файл, которая не прерывается. При этом записывается только один ...
0
голосов
1
ответ
32
показа
При вводе большого значения a, происходит переполнение. Как дальше работает программа? На месте a,b возникают неверные значения. Что происходит с a? [закрыт]
/*
Разработка программы обмена местами двух целочисленных
ячеек памяти без использования дополнительный памяти.
Программа должна запросить у пользователя два целый числа, затем
выполнить реализованный ...
0
голосов
1
ответ
46
показов
помогите разобраться stringReader.Read()
не могу понять, как реализовать этот метод.
TODO. Implement the method by reading the next character with StringReader.Read method.
Вот что у меня получилось
public static bool ReadNextCharacter(...
-1
голос
2
ответа
80
показов
Как построчно заменить текст в файле с помощью writeStream.write?
Есть файл:
<!DOCTYPE html>
<html lang="en">
someText
<head>
<meta charset="UTF-8">
<meta name="viewport" content="width=device-...
2
голоса
0
ответов
50
показов
Изменение отображения вводимого текста в консоли C++
Ситуация: в программе содержится строчка кода, позволяющая осуществить ввод с клавиатуры (cin>>/getline() ) и, соответственно, войти в поток ввода.
Проблема: при нажатии клавиш соответствующие ...
2
голоса
1
ответ
104
показа
C# ускорить запись в файл
Доброго времени суток!
У меня есть такое задание:
Разработайте ПО, которая будет разбивать числа от 1 до 1 000 000 000
на группы, при этом числа в каждой отдельно взятой группе не делятся
друг на ...
0
голосов
1
ответ
41
показ
Как заполнить ArrayList при помощи IntStream
Я создаю список обьектов через for, прохожу определенное кол-во раз и каждый раз создаю обьект и добавляю его в список, как мне переделать этот метод с использованием IntStream?
List<Post> ...
0
голосов
0
ответов
70
показов
Использую FFMPEG в Node.js для Live Stream по UDP и есть проблемы с длительностью воспроизведения
Реализовал поток аудио по UDP на сервер Node.js
Работает всё исправно и без задержек. Проблема в том, что спустя 4 минуты и 15-19 секунды, сервер перестаёт принимать буфер и воспроизведение ...
0
голосов
1
ответ
38
показов
Как отсортировать список исходя из значений другого списка
Есть список с сотрудниками List<Employee> employees и другой список List<Integer> employeeIds
Список сотрудников содержит поле Id, по которому и нужно произвести сортировку, а именно, ...
2
голоса
2
ответа
94
показа
В чём разница терминальных операций в Java Stream API: count() и collect(Collectors.counting())?
count()
и
collect(Collectors.counting())
Не дублирующий ли это функционал?
Или есть какая-то разница, тогда что предпочтительнее использовать?
Я пока не нашёл ситуаций, где второй не мог бы заменить ...
0
голосов
0
ответов
38
показов
Как использовать один и тот же файл в одном процессе с StreamWriter-ом
Посмотрел несколько сайтов, понятного мне решения(или работающего) я не нашел. С помощью StreamWriter программа записывает поступающий текст в txt (проще говоря парсер). При вводе определенной команде ...