public class Main {
static int x = 0;
public static void main(String[] args) throws InterruptedException {
Thread t1 = new Thread(() -> {
for (int i = 0; i < 1000; i++) x++;
});
Thread t2 = new Thread(() -> {
for (int i = 0; i < 1000; i++) x++;
});
t1.start();
t2.start();
Thread.sleep(100);
System.out.print(x);
}
}Please open Telegram to view this post
VIEW IN TELEGRAM
Что выведет код?
Anonymous Quiz
21%
А) 2000
46%
В) Меньше или равное 2000
18%
С) Ошибка компиляции
15%
D) 0
Phaser — это продвинутый синхронизатор из
java.util.concurrent, который позволяет потокам координироваться по фазам выполнения.В отличие от CountDownLatch и CyclicBarrier, он гибче: количество участников можно динамически добавлять и убирать.
• Поддерживает несколько фаз
• Гибко управляет количеством потоков
• Удобен для пошаговых алгоритмов
import java.util.concurrent.Phaser;
public class Main {
public static void main(String[] args) {
Phaser phaser = new Phaser(3);
Runnable task = () -> {
System.out.println(Thread.currentThread().getName() + " — фаза 1");
phaser.arriveAndAwaitAdvance();
System.out.println(Thread.currentThread().getName() + " — фаза 2");
};
new Thread(task).start();
new Thread(task).start();
new Thread(task).start();
}
}
👀 Phaser особенно полезен для задач с несколькими этапами синхронизации — например, симуляций, параллельных вычислений или координации батчевых операций
Please open Telegram to view this post
VIEW IN TELEGRAM
🔥1
Please open Telegram to view this post
VIEW IN TELEGRAM
🤣14👍1
Автор разбирает, почему внедрение AI может снижать продуктивность, раздувать время ревью и плодить уязвимости. И главное — как это лечить не магическими промптами, а инженерным пайплайном: SDD, TDD, узкие AI-ревьюеры, property-based testing и связка LLM с формальными анализаторами.
Please open Telegram to view this post
VIEW IN TELEGRAM
❤3
class Parent {
static String show() {
return "Parent";
}
String print() {
return show();
}
}
class Child extends Parent {
static String show() {
return "Child";
}
}
public class Main {
public static void main(String[] args) {
Parent p = new Child();
System.out.println(p.print());
}
}Please open Telegram to view this post
VIEW IN TELEGRAM
😁6🤔2🔥1
Это статический метод для создания ThreadLocal переменной с фабрикой начального значения. Каждый поток получает свою собственную копию объекта, а withInitial задаёт ленивый способ её создания — при первом вызове get().
import java.text.SimpleDateFormat;
import java.util.concurrent.*;
public class ThreadLocalExample {
// Безопасный форматтер без синхронизации
private static final ThreadLocal<SimpleDateFormat> dateFormat =
ThreadLocal.withInitial(() -> new SimpleDateFormat("yyyy-MM-dd"));
public static void main(String[] args) throws Exception {
ExecutorService pool = Executors.newFixedThreadPool(3);
for (int i = 0; i < 5; i++) {
final int taskId = i;
pool.submit(() -> {
String formatted = dateFormat.get().format(new java.util.Date());
System.out.println(Thread.currentThread().getName() + " -> " + formatted + " (task " + taskId + ")");
});
}
pool.shutdown();
}
}
Особенно полезен при хранении не потокобезопасных объектов (SimpleDateFormat, Random), изоляции пользовательской сессии/токена в вебе, переиспользовании тяжелых ресурсов без синхронизации.
Please open Telegram to view this post
VIEW IN TELEGRAM
⚡1
Please open Telegram to view this post
VIEW IN TELEGRAM
Официальный Java SDK для протокола Agent2Agent достиг версии 1.0.0. Теперь Java-разработчики могут строить агентные приложения, которые взаимодействуют с агентами на других языках и фреймворках.
Agent2Agent — это протокол, управляемый Linux Foundation (изначально представленный Google), который позволяет агентам на разных фреймворках и языках находить друг друга, делегировать задачи и обмениваться результатами.
Please open Telegram to view this post
VIEW IN TELEGRAM
class Parent {
static int a = initA();
static int initA() {
System.out.print("P ");
return 1;
}
Parent() {
System.out.print("p ");
}
}
class Child extends Parent {
static int b = initB();
static int initB() {
System.out.print("C ");
return 2;
}
Child() {
System.out.print("c ");
}
}
public class Main {
public static void main(String[] args) {
new Child();
}
}
Please open Telegram to view this post
VIEW IN TELEGRAM
ReentrantReadWriteLock — это улучшенная альтернатива synchronized, позволяющая одновременно выполнять несколько чтений, но блокировать доступ на запись.
Он состоит из двух независимых замков:
• readLock() — совместимый, позволяет многим потокам читать параллельно
• writeLock() — эксклюзивный, разрешает только одному потоку писать
import java.util.concurrent.locks.*;
public class Main {
private static final ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
private static int value = 0;
public static void main(String[] args) {
Runnable reader = () -> {
lock.readLock().lock();
try {
System.out.println("Чтение: " + value);
} finally {
lock.readLock().unlock();
}
};
Runnable writer = () -> {
lock.writeLock().lock();
try {
value++;
System.out.println("Запись: " + value);
} finally {
lock.writeLock().unlock();
}
};
new Thread(reader).start();
new Thread(writer).start();
}
}
👀 ReentrantReadWriteLock особенно полезен, когда чтений гораздо больше, чем записей — например, в кэшах, справочниках или аналитических сервисах
Please open Telegram to view this post
VIEW IN TELEGRAM
Collectors.partitioningBy() — это коллектор из Java Stream API, который разделяет элементы потока на две группы (true/false) на основе заданного предиката, возвращая Map<Boolean, List<T>>.
import java.util.*;
import java.util.stream.*;
import java.util.function.Predicate;
public class PartitioningByExample {
public static void main(String[] args) {
List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);
// Разделение чисел на четные и нечетные
Map<Boolean, List<Integer>> partitioned = numbers.stream()
.collect(Collectors.partitioningBy(n -> n % 2 == 0));
System.out.println("Четные: " + partitioned.get(true)); // [2, 4, 6, 8, 10]
System.out.println("Нечетные: " + partitioned.get(false)); // [1, 3, 5, 7, 9]
// Строки по длине
List<String> words = Arrays.asList("яблоко", "груша", "слива", "апельсин", "лимон");
Map<Boolean, List<String>> byLength = words.stream()
.collect(Collectors.partitioningBy(word -> word.length() > 5));
System.out.println("\nКороткие слова (≤5 букв): " + byLength.get(false));
System.out.println("Длинные слова (>5 букв): " + byLength.get(true));
// С дополнительным коллектором - подсчет количества
Map<Boolean, Long> countPartition = numbers.stream()
.collect(Collectors.partitioningBy(
n -> n > 5,
Collectors.counting()
));
System.out.println("\nЧисел ≤5: " + countPartition.get(false));
System.out.println("Чисел >5: " + countPartition.get(true));
}
}
👀 Особенно полезен для разделения данных на прошедшие/не прошедшие валидацию, категоризации на успешные/ошибочные операции, статистического анализа.
Please open Telegram to view this post
VIEW IN TELEGRAM
👍5❤2🔥2