import java.util.Arrays;
import java.util.List;

public class FPExample {
    public static void main(String[] args) {
        // 創(chuàng)建一個(gè)字符串列表
        List<String> words = Arrays.asList("apple", "banana", "orange", "pear");

        // 使用函數(shù)式編程方式進(jìn)行操作
        words.stream()
             .filter(word -> word.length() > 5) // 過濾長度大于5的單詞
             .map(String::toUpperCase) // 將單詞轉(zhuǎn)換為大寫
             .forEach(System.out::println); // 打印結(jié)果
    }
}

-- 創(chuàng)建一個(gè)示例表
CREATE TABLE students (
  id INT PRIMARY KEY,
  name VARCHAR(50),
  age INT
);

-- 查詢年齡小于20歲的學(xué)生姓名
SELECT name FROM students WHERE age < 20;

% 定義一些邏輯規(guī)則和事實(shí)
parent(john, jim).
parent(john, ann).
parent(jim, lisa).
parent(lisa, mary).

% 定義一個(gè)遞歸規(guī)則，判斷某人是否是某人的祖先
ancestor(X, Y) :- parent(X, Y).
ancestor(X, Y) :- parent(X, Z), ancestor(Z, Y).

% 查詢某人的祖先
?- ancestor(john, mary).

public class ConcurrentExample {
    public static void main(String[] args) {
        // 創(chuàng)建一個(gè)共享的計(jì)數(shù)器對象
        Counter counter = new Counter();

        // 創(chuàng)建多個(gè)線程并發(fā)執(zhí)行增加計(jì)數(shù)的操作
        Thread thread1 = new Thread(() -> {
            for (int i = 0; i < 1000; i++) {
                counter.increment();
            }
        });

        Thread thread2 = new Thread(() -> {
            for (int i = 0; i < 1000; i++) {
                counter.increment();
            }
        });

        // 啟動線程
        thread1.start();
        thread2.start();

        // 等待線程執(zhí)行完畢
        try {
            thread1.join();
            thread2.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        // 輸出計(jì)數(shù)器的值
        System.out.println("Counter value: " + counter.getValue());
    }
}

class Counter {
    private int value = 0;

    public void increment() {
        value++;
    }

    public int getValue() {
        return value;
    }
}

public class GenericExample<T> {
    private T value;

    public GenericExample(T value) {
        this.value = value;
    }

    public T getValue() {
        return value;
    }

    public void setValue(T value) {
        this.value = value;
    }

    public static <E> void printArray(E[] array) {
        for (E element : array) {
            System.out.println(element);
        }
    }

    public static void main(String[] args) {
        GenericExample<String> example1 = new GenericExample<>("Hello");
        System.out.println(example1.getValue());

        GenericExample<Integer> example2 = new GenericExample<>(123);
        System.out.println(example2.getValue());

        Integer[] numbers = {1, 2, 3, 4, 5};
        printArray(numbers);

        String[] words = {"apple", "banana", "cherry"};
        printArray(words);
    }
}

public class UserService {
    public void saveUser(User user) {
        // 保存用戶信息的業(yè)務(wù)邏輯
        // ...
    }
}

@Aspect
public class LoggingAspect {
    @Before("execution(* com.example.UserService.saveUser(..))")
    public void beforeSaveUser(JoinPoint joinPoint) {
        // 在saveUser方法執(zhí)行之前執(zhí)行的通知
        System.out.println("Before saving user: " + joinPoint.getArgs()[0]);
    }
}

@Configuration
@EnableAspectJAutoProxy
public class AppConfig {
    // 配置其他組件和Bean
    // ...
}

public static void main(String[] args) {
    AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(AppConfig.class);
    UserService userService = context.getBean(UserService.class);

    User user = new User("John Doe");
    userService.saveUser(user);
}

implementation 'io.reactivex.rxjava3:rxjava:3.1.2'

import io.reactivex.rxjava3.core.Observer;
import io.reactivex.rxjava3.disposables.Disposable;

public class LoginObserver implements Observer<User> {
    @Override
    public void onSubscribe(Disposable d) {
        // 當(dāng)觀察者訂閱時(shí)執(zhí)行的操作
    }

    @Override
    public void onNext(User user) {
        // 用戶登錄成功后執(zhí)行的操作
        String welcomeMessage = "Welcome, " + user.getUsername();
        System.out.println(welcomeMessage);
    }

    @Override
    public void onError(Throwable e) {
        // 處理錯(cuò)誤的操作
    }

    @Override
    public void onComplete() {
        // 用戶登錄完成后執(zhí)行的操作
    }
}

import io.reactivex.rxjava3.core.Flowable;

public class LoginFlow {
    private Flowable<User> loginFlow;

    public LoginFlow() {
        // 創(chuàng)建登錄流
        loginFlow = Flowable.create(emitter -> {
            // 模擬用戶登錄過程
            // ...

            // 當(dāng)用戶登錄成功后，發(fā)射用戶信息
            User user = new User("John Doe");
            emitter.onNext(user);

            // 完成登錄流
            emitter.onComplete();
        }, BackpressureStrategy.BUFFER);
    }

    public Flowable<User> getLoginFlow() {
        return loginFlow;
    }
}

public static void main(String[] args) {
    LoginFlow loginFlow = new

 LoginFlow();
    Flowable<User> loginStream = loginFlow.getLoginFlow();

    // 訂閱登錄流并處理事件
    loginStream.subscribe(new LoginObserver());
}

public interface Shape {
    void draw();
}

public class Rectangle implements Shape {
    @Override
    public void draw() {
        System.out.println("Drawing a rectangle");
    }
}

public class Circle implements Shape {
    @Override
    public void draw() {
        System.out.println("Drawing a circle");
    }
}

import java.util.ArrayList;
import java.util.List;

public class Canvas implements Shape {
    private List<Shape> shapes;

    public Canvas() {
        shapes = new ArrayList<>();
    }

    public void addShape(Shape shape) {
        shapes.add(shape);
    }

    @Override
    public void draw() {
        System.out.println("Drawing canvas:");
        for (Shape shape : shapes) {
            shape.draw();
        }
    }
}

public static void main(String[] args) {
    Canvas canvas = new Canvas();
    canvas.addShape(new Rectangle());
    canvas.addShape(new Circle());
    canvas.draw();
}

Drawing canvas:
Drawing a rectangle
Drawing a circle

import java.util.ArrayList;
import java.util.List;

public class Button {
    private List<ActionListener> listeners;

    public Button() {
        listeners = new ArrayList<>();
    }

    public void addActionListener(ActionListener listener) {
        listeners.add(listener);
    }

    public void click() {
        System.out.println("Button clicked");
        // 觸發(fā)按鈕點(diǎn)擊事件
        for (ActionListener listener : listeners) {
            listener.onActionPerformed(new ActionEvent(this));
        }
    }
}

public class TextBox implements ActionListener {
    @Override
    public void onActionPerformed(ActionEvent event) {
        System.out.println("Text box updated: " + event.getSource());
    }
}

public static void main(String[] args) {
    Button button = new Button();
    TextBox textBox = new TextBox();

    button.addActionListener(textBox);

    // 模擬用戶點(diǎn)擊按鈕
    button.click();
}

Button clicked
Text box updated: Button@2c8d66b2