FEAT: Add listener to Future for compatibility with spymemcached

[singsangssong]

🔗 Related Issue

• https://github.com/jam2in/arcus-works/issues/725

⌨️ What I did

Spymemcached와의 호환성을 맞추기 위해 Future 객체에 리스너(listener)를 추가하는 기능을 구현했습니다. 이제 .addListener()를 사용하여 작업 완료 후 실행될 로직을 등록할 수 있습니다.

spymemcached에서는 GetFuture 클래스가

• AbstractListenableFuture 클래스 추가
  • ReentrantLock을 사용하여 리스너 목록 접근 시의 안정성을 확보했습니다.
• ExecutorService를 통한 리스너 실행
  • I/O 스레드를 방해하지 않도록, 별도의 스레드 풀에서 리스너를 실행하도록 구현했습니다.
• 기존 Future 클래스 구조 변경
  • OperationFuture, BulkGetFuture클래스는AbstractListenableFuture를 상속받아 리스너 기능을 갖도록 구조를 변경했습니다.
  • GetFuture의 경우, Spymemcached와 달리 Arcus의 기존 구조인 GetFuture extends OperationFuture를 유지했습니다. 이를 통해 GetFuture는 OperationFuture로부터 리스너 기능을 자동으로 상속받으며, 자신은 GetResult 객체를 처리할 수 있도록 했습니
• MemcachedClient 수정
  • asyncGet, asyncGets, asyncStore 등 OperationFuture를 생성하는 모든 메소드에서 ExecutorService를 주입하도록 수정했습니다.

---

• 현재 테스트코드는 따로 구현되지 않은 상태입니다. 테스트코드가 필요하다면 추가하도록 하겠습니다.

[uhm0311]

Generic 사용이 과하다는 느낌이 있는데, spymemcached에 맞추어야 하는 건가요?

[singsangssong]

일단 구현은 spymemcached를 기준으로 맞췄습니다.
spymemcached 구현에서는 타입 안정성을 고려하지 않은 코드가 몇몇 있었고, 이것이 warning 에러를 발생시켜 ci가 실패했습니다. 이때문에 타입안정성을 확보하고 ci를 성공시키고자 제네릭이 많아졌습니다.

[oliviarla]

@singsangssong
spymemcached와 구현 상 다른점이 있다면 왜 다르게 구현했는지에 대한 설명을 첫 코멘트에 추가해주시면 좋겠습니다.

[singsangssong]

구현상 다른점은 첫 코멘트에 볼드체로 표시해두었습니다.

[singsangssong]

간단하게 테스트코드까지 추가하였습니다. 해당 리스너를 테스트할 곳이 마땅하지 않아서 test/java/net/spy/memcached에 FutureListenerTest클래스에 작성하였습니다.

[oliviarla]

• (@singsangssong) ConnectionFactoryBuilder 에도 ExecutorService 설정하는 기능이 있으니 함께 추가되어야 합니다.

• (@uhm0311 @jhpark816) 지금 Listener 클래스를 하나만 두고 있어서 실제 spymemcached에 존재하는 BulkGetCompletionListener, GetCompletionListener 를 생성해 사용하는 경우 arcus java client에는 해당 클래스가 없으므로 바로 마이그레이션이 불가능합니다. 저는 이부분도 최대한 호환하는게 좋다는 입장인데 어떻게 생각하시나요?

[oliviarla]

이 메서드를 여기서 호출할 필요 없습니다.

[oliviarla]

boolean isDefaultExecutorService(); 도 추가해야 할 것 같습니다.

[oliviarla]

@singsangssong BulkGetCompletionListener, GetCompletionListener 클래스도 spymemcached와 동일하게 추가해주시면 좋겠습니다.

[singsangssong]

이전 리뷰를 통해서 제네릭을 제거한 구조인데, 이를 기존 spymemcached처럼 제네릭을 추가하나요?

지금 Listener 클래스를 하나만 두고 있어서 실제 spymemcached에 존재하는 BulkGetCompletionListener, GetCompletionListener 를 생성해 사용하는 경우 arcus java client에는 해당 클래스가 없으므로 바로 마이그레이션이 불가능합니다.

해당 코멘트로는 구현을 기존 spymemcached에서 가져오는 것으로 이해했습니다.
spymemcached에서는 GetFuture의 필드로 OperationFuture를 가지며, arcus는 OperationFuture를 상속받고 필드로 GetResult를 필드로 가지고 있습니다. 이 점 때문에 첫 커밋에서는 GetCompletionListener없이GetFuture를 구현했습니다.

[oliviarla]

spymemcached 호환을 맞추지 않기로 결정되어 close합니다.